apache/beam
Documented errors, page 13 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Key coder must be deterministic | validation | error | beam, coder, determinism, watch |
| Missing language specification, unknown input fields, or… | validation | error | yaml, beam-yaml, expression-validation |
| Missing requirement declaration | validation | error | python, apache-beam, pipeline-requirements, validation |
| Missing serialized typeDescriptor | validation | error | java, beam, schemacoder, protobuf |
| Ordering of entries in a Map may be non-deterministic. | exception | error | java, beam, coders, determinism |
| PartitionFn yielded a | exception | error | python, apache-beam, partitionfn, type-mismatch |
| please provide a parameters function | validation | error | java, neo4j, apache-beam, missing-required-configuration |
| %s | exception | error | testing, assertion, apache-beam |
| Service endpoint must be a URI, got | validation | error | kinesis, uri, config, schema-transform |
| timer using DoFn doesn't use a KV as PCollection input… | validation | error | go, apache-beam, timers, stateful, kv |
| Transform " " was applied to the output of " " but " "… | exception | error | python, apache-beam, pipeline, typecheck |
| Unable to read file(s) after retrying | exception | error | java, io, file-read, retry-exhausted |
| unimplemented | exception | error | python, apache-beam, not-implemented, triggers |
| We have observed a row of size | exception | error | bigquery, gcp, row-size-limit, schema |
| Append to stream failed with Status Code . The stream may… | exception | error | bigquery, storage-write, stream, grpc, gcp |
| Cannot convert from a JSON value. | validation | error | python, type-error, deserialization, json, google-cloud |
| ChangeStreamName can't be empty | validation | error | java, apache-beam, google-cloud-spanner, change-streams, validation |
| Does not support converting unknown type value: " +… | exception | error | java, beam, bigquery, avro, type-mismatch |
| Error processing struct to row | exception | error | spanner, schema, type-conversion, java |
| failed to reprocess with merged windows, got | error_code | error | go, beam, direct-runner, windowing, sessions |
| Failure getting proto descriptor. Successful output will… | console | warning | bigquery, storage-api, protobuf, schema |
| Input to operation must be rebatched from type to . This is… | console | warning | performance, batching, inefficiency, runner |
| Malformed class : state declaration field is not accessible. | exception | error | java, apache-beam, reflection, state-api, illegal-access |
| neo4j session was not initialized correctly | exception | error | java, neo4j, apache-beam, initialization |
| prism consistency error: trying to remove a timer for a key… | panic | error | go, panic, timer, internal-state, beam-prism |
| () got multiple values for argument | exception | error | python, apache-beam, dataframe-api, duplicate-argument |
| Type of @Element must match the DoFn type | validation | error | java, apache-beam, schema |
| Unable to encode element ' | exception | error | beam, java, coders, structural-value |
| Unknown access pattern | validation | error | apache-beam, fn-api-runner, side-inputs, unsupported-operation, urn |
| bad userfn | exception | error | go, beam, serialization, userfn |
| cannot call sideInput() in a null context | exception | error | |
| coder must not be nil | panic | error | go, apache-beam, coder, nil-check, panic |
| couldn't decode characteristic for variant | panic | error | go, beam, prism, config, yaml, panic |
| delete does not delete containers. | exception | error | azure, blob-storage, delete, container, unsupported-operation |
| error opening source file | exception | error | go, zip, io, corrupt-file |
| Failed assert: unmatched elements | exception | error | python, apache-beam, assertion, windowing, test |
| Failed to parse DirectedReadOptions from string: +… | validation | error | java, spanner, json, protobuf, configuration |
| Instance connection URI cannot be empty | validation | error | python, configuration, cloudsql, apache-beam |
| More than attempts to call AppendRows failed. Last… | exception | error | bigquery, storage-write, grpc, permission-denied, retry-exhausted, gcp |
| Opcode should be one of ParDo or Combine, but it is | panic | error | go, apache-beam, translation, panic |
| projectId can't be empty | validation | error | java, beam, spanner, config, validation |
| proto type is unsupported. | exception | error | bigquery, protobuf, unsupported-type, java |
| Resolved start version | validation | error | java, delta-lake, cdc, argument-validation |
| Storage API triggering frequency option will be ignored is… | console | warning | java, apache-beam, bigquery, configuration |
| Table specification [ ] is not in one of the expected… | validation | error | bigquery, parsing, argument-validation |
| TableCell can hold arbitrary instances, which may be… | exception | warning | java, beam, bigquery, determinism, coder |
| This function must only be called under the lock self.lock. | validation | error | python, apache-beam, range-tracker, threading, lock |
| Unable to match files in bucket | exception | error | gcs, io, network |
| Unable to parse | exception | error | json, parsing, pipeline-options, template |
| Unable to pickle fn : . User code must be serializable… | exception | error | python, apache-beam, pickling, serialization |
| Unexpected data | exception | error | python, apache-beam, windows, fn-api-runner |
| Unsupported Beam to JSON type | exception | error | java, json-schema, schemas, type-conversion |
| Value " " is out of range for the type of the field defined… | validation | error | java, beam, schema, data-conversion, json |
| varint too long | exception | error | go, beam, coder, data-corruption, serialization |
| Attempting to emit an element outside of a @ProcessElement… | exception | error | beam, dofn, lifecycle, illegal-state |
| Cannot output timer with output timestamp | exception | error | beam, timer, timestamp, allowed-timestamp-skew |
| Checksum operation failed | exception | error | python, apache-beam, azure-blob-storage, filesystem-io, error-wrapping |
| DNP: Updating watermark failed due to overlapping | console | warning | java, apache-beam, bigtable, change-stream, watermark |
| Expression roots must have been created with to_dataframe. | exception | error | python, apache-beam, dataframe-api, expression-tree |
| Failed to list first page of HL7v2 messages from | exception | error | java, google-cloud-healthcare, hl7v2, pagination, io |
| Forbidden IOException when reading from InputStream | exception | error | java, io, coders, decoding |
| found params, want > | validation | error | go, apache-beam, dofn-signature, side-input |
| Invalid method ' '. Supported methods are: . | validation | error | beam-sql, bigquery, invalid-property, ddl |
| len mismatch decoding a | exception | error | go, beam, iterable, decoding, length-mismatch |
| optional generic parameter not bound | validation | error | go, beam, generics, type-binding |
| other must be a DeferredDataFrame or DeferredSeries… | exception | error | pandas, apache-beam, dataframe, order-sensitive |
| Predicate node ' ' should be a boolean expression, but was | exception | error | beam-sql, bigquery, predicate-pushdown, type-mismatch |
| does not support predicate/project push-down, yet non-empty… | exception | error | |
| sentence-transformers is required to use… | exception | error | python, apache-beam, importerror, huggingface, optional-dependency |
| Simulating failure for | exception | warning | java, pubsub, test-failure-injection |
| Starting version or timestamp must be specified. | validation | error | java, delta-lake, cdc, apache-beam, missing-argument |
| Unable to find 'public static CoderProvider… | exception | error | beam, java, reflection, coders |
| unable to get row encoder | panic | error | beam-go, jdbc, encoding, reflection, panic |
| unable to map to pipepb.AtomicType | exception | error | go, apache-beam, schema, atomic-type |
| A method marked with SchemaCreate in class | exception | error | java, beam-schema, annotation, reflection |
| A transform with label | exception | error | python, apache-beam, runtime-error, duplicate-label |
| combine_fn must be provided | validation | error | python, apache-beam, userstate, combining-value, missing-argument |
| could not complete request | exception | error | request-response, future, timeout, apache-beam |
| Could not find subtransform to copy: | exception | error | python, apache-beam, pipeline-graph, internal-invariant |
| CustomCoder implementations must override… | exception | error | java, apache-beam, coders, determinism |
| DoFn %r has multiple TimerSpecs with the same name | validation | error | python, apache-beam, timers, duplicate-name, validation |
| Either reidentifyConfig or reidentifyTemplateName need to… | validation | error | java, apache-beam, google-cloud-dlp, builder-validation, illegal-argument-exception |
| Empty PCollection accessed as a singleton view. | exception | error | java, apache-beam, empty-collection, no-such-element |
| encoding , expected | exception | error | go, beam, encoding, serialization |
| Equality field is not a top-level column of schema | exception | error | iceberg, cdc, schema-mismatch |
| error in coping file | exception | error | go, io, network, download |
| error retrieving page | exception | error | aws, s3, pagination, network |
| Expected input schema with a 'data' (BYTES) field, a… | validation | error | kinesis, schema, bytes, schema-transform |
| Expected state to be PENDING or STARTED, but was… | exception | error | firestore, qos, illegal-state, lifecycle, java, apache-beam |
| failed to make node with node id | exception | error | go, apache-beam, pcollection, windowing-strategy |
| failed to read metadata from context | exception | error | grpc, go, metadata, apache-beam |
| Failed to retrieve or create secret bytes for secret | exception | error | python, apache-beam, hsm, kms, secret-manager, api-error |
| Found two matching allowlist classes | exception | error | configuration, ambiguity, allowlist |
| Invalid GCS location: %r. Writing to BigQuery with… | validation | error | gcp, bigquery, gcs, configuration |
| Logical types don't match and cannot be merged… | validation | error | java, beam, schema, logical-type |
| . . Row: %r | exception | error | bigquery, python, json, serialization |
| SQL type not supported: | exception | error | beam-sql, cep, calcite, sql-type, literal |
| The input to this transform does not appear to be an error… | validation | error | yaml, beam-yaml, schema, error-handling |
| Unable to automatically infer a Coder for the Kafka… | exception | error | |
| Unknown access_pattern | exception | error | python, apache-beam, side-input |