apache/beam
Documented errors, page 18 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Method expand has not been implemented. | exception | critical | abstract-method, transform, pipeline-build |
| No proto encoding for PaneInfoCoder, always part of… | exception | error | python, apache-beam, environment, java, docker, expansion-service |
| Only objects with the same number of days, start date and… | exception | error | java, apache-beam, windowing, incompatibility |
| panic(formatParDoError(dofn, len(ret), 6)) | panic | error | go, apache-beam, pardo, panic, signature-mismatch |
| PartitionSpec with id | exception | error | iceberg, java, serialization, partition-spec, lookup |
| ProcessElement uses a StateProvider, but no State structs… | validation | error | go, apache-beam, dofn, state, reflection |
| reconciling for ToType | exception | error | go, apache-beam, schema, registry, logical-type |
| with no or | exception | error | java, beam, fusion, deduplication, invariant |
| SortOrder with id not found in sortOrders map | exception | error | iceberg, java, serialization, sort-order, lookup |
| split[ ] error from SDK | exception | error | |
| structx: FieldIndexByTag of non-struct type | panic | error | go, panic, reflection, structx |
| Unexpected null result. | exception | error | null, internal, beam, invariant |
| Unknown scan type | exception | error | iceberg, java, apache-beam, enum, unknown-value |
| Unparsable resource hint: | exception | error | java, apache-beam, resource-hints, cli-options, parsing |
| unparsable resource hint | panic | error | go, beam, cli, resource-hints, config |
| Upgrading KafkaIO write transforms that have… | exception | error | java, apache-beam, kafka, pipeline-upgrade, unsupported-feature |
| while executing Process for | error_code | error | go, apache-beam, execution-plan, bundle-processing |
| Write disposition is not supported for streaming inserts to… | validation | error | bigquery, python, apache-beam, streaming-inserts |
| BigQuery test was not shutdown previously. Table is | exception | error | java, junit, google-bigquery, test-rule, lifecycle |
| Bundle processing associated with | exception | error | apache-beam, sdk-worker, bundle-failure |
| compression_type must be CompressionType object but was | validation | error | python, apache-beam, io, type-mismatch, compression |
| Config schema provided with the expansion request | exception | error | java, beam, schema |
| Encountered an Atomic type that is not currently supported… | exception | error | python, apache-beam, managed-transform, invalid-argument, io |
| error encoding response | http | error | |
| error in message batch | exception | error | nats, jetstream, batch, consumer |
| Error while converting FieldSchema to HCatFieldSchema | exception | error | java, schema, hcatalog, hive |
| failed to create data client on | exception | critical | go, apache-beam, grpc, stream |
| Input key coder does not match output key coder for… | validation | error | python, apache-beam, pipeline-validation, coders |
| Instruction id was registered twice | exception | error | beam, grpc, multiplexer, duplicate-registration |
| Invalid tag. | validation | error | python, apache-beam, trigger, state, valueerror |
| lenientFormat(errorMessageTemplate, p1, p2) | validation | error | java, apache-beam, null-check, illegal-argument |
| Missing type parameter for transform at | exception | error | python, apache-beam, yaml, config |
| pcollection must be of non-composite type | panic | error | go, panic, type-mismatch, beam-transform |
| .verifyCompatibility() should never be called. It is a… | exception | error | java, beam, windowing, unsupported-operation |
| table name missing components | exception | error | bigquery, parsing, format, beam-io |
| The confidence must be between 0 and 1 | validation | error | java, beam, sketching, count-min-sketch, validation |
| The current runner does not support SDF-based Kafka read… | exception | error | java, kafka, runner, sdf, dataflow |
| Unable to construct FactoryFn | exception | error | kafka, reflection, factory, configuration, beam-io |
| Unable to dump heap: | console | warning | java, apache-beam, heap-dump, jvm, oom |
| unexpected number of parameters in method | validation | error | go, apache-beam, sdf, watermark-estimator, parameter-count |
| array len mismatch. decoding | validation | error | go, apache-beam, decoding, array, coder |
| artifact not staged | validation | error | gcs, artifact-staging, manifest, state |
| can not be serialized to Json | exception | error | jackson, serialization, aws, credentials |
| Cannot create a temporary directory for root path prefix | validation | error | python, apache-beam, io, path, configuration |
| Cannot explodeWindows() on WindowedValue builder; use… | exception | error | java, apache-beam, windowed-value, unsupported-operation |
| chunk_to_dict_fn is deprecated, use embeddable_to_dict_fn | console | warning | python, deprecation, apache-beam, rag |
| Could not unmarshal SourceConfig | panic | error | go, apache-beam, json, unmarshal, panic |
| could not unmarshal timer coder from | exception | error | go, apache-beam, coder, timer |
| Dataflow pipeline failed. State | exception | error | dataflow, gcp, pipeline, remote-execution |
| Either size or error should be set. Received | validation | error | python, apache-beam, approximateunique, mutually-exclusive |
| Encountered unsupported parameter(s) in read_gbq | validation | error | python, apache-beam, bigquery, api |
| Error while attempting to create bucket gs:// | exception | error | gcs, interrupted, concurrency |
| Error writing to Solr (no attempt made to retry) | exception | error | java, beam, solr, retry, write |
| Exception thrown when outputting WindowedValue | exception | error | java, beam, windowed-value, coder, runtime-exception |
| Expected distinct components | exception | error | merge, components, conflict |
| Expected state to be STARTED, but was PENDING | exception | error | firestore, qos, illegal-state, lifecycle, java, apache-beam |
| failed to create state client | exception | error | go, grpc, beam, rpc |
| Failed to decode schema due to an issue with Field proto | validation | error | python, schema, namedtuple, protobuf |
| failed to run query | exception | error | database, sql, query, go |
| Invalid transform specification at | exception | error | yaml, beam-yaml, pipeline-definition, config-validation |
| Metadata operation failed | exception | error | python, apache-beam, azure-blob-storage, filesystem-io, error-wrapping |
| Missing language specification. Must specify a language… | validation | error | yaml, beam-yaml, missing-language |
| No type parameter named | exception | error | java, generics, reflection, apache-beam |
| node in graph has undefined coder | validation | error | beam, go, graph, coder |
| One or more ErrorHandlers aren't closed, and this pipeline… | exception | error | java, beam, error-handler, lifecycle, validation |
| replace(method= ) is not supported because it is order… | exception | error | apache-beam, dataframe, pandas, replace, order-sensitive |
| RexNode not supported: | exception | error | beam-sql, cep, calcite, unsupported-operation, rexnode |
| SDFBoundedSourceRestrictionProvider can only utilize… | validation | error | apache-beam, python, splittable-dofn, boundedsource, type-mismatch |
| The type is not supported | exception | error | java, nfa, cep, schema, unsupported-type |
| Unknown command " ". Possible values are | validation | error | java, cli, invalid-argument, validation |
| Unknown or unsupported time domain | exception | error | beam, timer, time-domain, illegal-argument |
| Unregistering consumer which was not registered. | exception | error | java, beam-fn, grpc-multiplexer, lifecycle |
| unstack() is only supported on DataFrames if unstacked… | exception | error | apache-beam, dataframe, pandas, dtype |
| Unsupported proto type | exception | error | protobuf, beam, unsupported-type |
| accumulation_mode must be provided for non-trivial triggers | validation | error | python, apache-beam, windowing, triggers |
| cannot encode a null Map | exception | error | java, beam, coders, null |
| Cannot find Spanner table. | exception | error | java, beam, spanner, schema, table |
| CreateTracker has unexpected number of parameters | validation | critical | go, apache-beam, splittable-dofn, panic |
| Error closing FlightStream | console | error | |
| Error creating Data Catalog client | exception | error | apache-beam, datacatalog, java, gcp, credentials |
| Index out of bounds for positional parameter | validation | error | sql, parameters, beam |
| invalid pcollection to flatten: index | exception | error | beam, pipeline-construction, validation |
| Invalid subseconds for Timestamp with precision . | exception | error | python, apache-beam, timestamp, precision, range-check |
| invoker: has > 5 return values, which is not permitted | panic | error | go, apache-beam, dofn, arity, panic |
| Kafka metadata exists for shard | exception | critical | kafka, exactly-once, group-id, state-conflict, beam-io |
| Not expected to access DoFn.StartBundleContext from… | exception | error | apache-beam, java, testing, dofn |
| NotImplemented | exception | error | not-implemented, abstract-method, pipeline-result, runner |
| Number of components does not match number of coders. | exception | error | python, apache-beam, coding, tuple, arity-mismatch |
| Only strings allowed as map keys when converting from AVRO… | validation | error | python, apache-beam, avro, schema, map |
| panic(formatParDoError(dofn, len(ret), 3)) | panic | error | go, apache-beam, pardo, panic, signature-mismatch |
| Postgres reads require disableAutoCommit to be true… | console | warning | jdbc, postgres, configuration, autocommit, beam-io |
| RateLimitServiceStub is null | exception | error | grpc, rate-limiting, envoy, null-check, initialization |
| Received 'None' as the value for the field | exception | error | bigquery, python, schema, null |
| is splittable and uses state, but these are not compatible | exception | error | java, apache-beam, splittable-dofn, state |
| = not supported for | exception | error | python, apache-beam, dataframe-api, not-implemented |
| TableRow can hold arbitrary instances, which may be… | exception | error | java, bigquery, apache-beam, coder, non-deterministic |
| TableRows are not deterministic. | exception | warning | java, beam, bigquery, determinism, coder |
| There is already active job named | exception | error | python, apache-beam, dataflow, name-conflict |
| This provider of type | validation | error | python, apache-beam, yaml, provider, unsupported-operation |
| Transform with URN could not be translated | exception | error | java, proto, translation, pardo |