apache/beam
Documented errors, page 23 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Encountered an unexpected node type | exception | error | java, apache-beam, mongodb, sql, predicate-pushdown |
| error decoding buckets | exception | error | mongodb, go, decoding, aggregation |
| error getting stream | exception | error | nats, jetstream, stream, not-found, beam-io |
| Error in computing splits, split is null in InputSplits… | exception | error | hadoop, inputformat, null-pointer, split-computation |
| Failed to read Parquet footer for | exception | error | java, parquet, file-read, delta-lake |
| failed to stage Go worker binary | exception | error | artifact-staging, file-not-found, grpc, go-worker-binary |
| For a cycling sequence generator, both 'start' and 'end'… | validation | error | beam-sql, datagen, missing-config |
| from_runner_api_parameter does not handle empty or None… | exception | error | apache-beam, python, pubsub, missing-required-argument, deserialization |
| get_dummies() of non-categorical type is not supported… | exception | error | apache-beam, dataframe, deferred-columns, categorical, pandas |
| input_type could only be 'bytes' or 'fileio' | validation | error | validation, constructor-argument, dicom, python, apache-beam |
| Map value type cannot be null. | validation | error | java, apache-beam, firestore, schema-validation |
| No fallback. | exception | error | python, apache-beam, coding, fallback, serialization |
| No Op handler should not be closed. This implies this IO is… | validation | error | java, apache-beam, error-handling, no-op-handler, misconfiguration |
| No TableProvider registered for table type | exception | error | beam-sql, metastore, provider-lookup |
| offset exceeds the buffer limit. offset: , limit: | exception | error | java, apache-beam, io, argument-validation |
| is not implemented yet. If support for is important to you… | exception | error | python, apache-beam, dataframe-api, not-implemented |
| render DOT failed | exception | error | go, apache-beam, graphviz, template, io |
| shardsNumber must be greater than 0. | validation | error | java, configuration, snowflake, streaming |
| Text payload is not valid UTF-8. | validation | error | solace, java, utf-8, encoding, charset |
| The number of failing elements within the window %r… | exception | error | python, apache-beam, data-quality, threshold |
| Too many matches | exception | warning | python, apache-beam, dataflow, metrics |
| Unable to get BigQuery response after retrying | exception | error | java, gcp, bigquery, retry, table-read |
| Unable to handle state requests for ProcessBundleDescriptor… | exception | error | apache-beam, state-handler, user-state |
| Unable to translate beam type | exception | error | spanner, beam-schema, type-conversion, java |
| Unconvertable type | validation | error | avro, beam-schema, type-mismatch, python |
| Unexpected type | validation | error | avro, beam, schema-conversion, unexpected-type |
| unknown artifact type | exception | error | apache-beam, staging, artifacts, protobuf |
| batch: failed to marshal worker UUID | panic | error | go, apache-beam, uuid, panic |
| Builder method name has to be explicitly allowed | exception | error | java, security, allowlist, beam-expansion-service |
| Cannot provide because does not implement the interface | exception | error | java, serialization, hadoop, beam |
| Could not import joblib in this execution environment. For… | exception | error | python, apache-beam, sklearn, dependency, import |
| Could not parse the provided YAML stream into a non-trivial… | exception | error | java, yaml, config, empty-input |
| Error handling output | validation | error | apache-beam, yaml, partitioning, configuration |
| Expected state to be PENDING or STARTED, but was… | exception | error | firestore, qos, illegal-state, lifecycle, java, apache-beam |
| Failed to decode Schema due to an error decoding Field… | exception | error | java, apache-beam, protobuf, schema |
| Found incorrectly annotated property methods, if a method… | validation | error | java, apache-beam, annotations, json, pipeline-options |
| Hadoop Writable may be non-deterministic. | validation | error | java, hadoop, writable, determinism, coder |
| invalid float encoding for | validation | error | go, apache-beam, decoding, serialization, corrupt-data |
| Mismatch of length mask when reading a record. Expected | exception | error | java, beam, tfrecord, corruption, checksum |
| No cron schedule provided for VertexModelMonitoringV2 in… | exception | error | apache-beam, vertex-ai, streaming, scheduling |
| object must have 'gs' scheme | validation | error | gcs, url, validation, apache-beam |
| Primary restriction %#v is not done. Check that the… | error_code | error | go, apache-beam, splittable-dofn, restriction-tracker |
| RuntimeException | exception | error | java, coders |
| at key is not supported | exception | error | java, apache-beam, xml, unsupported-type |
| SolaceIO.Write.UnboundedSolaceWriter.Context: BoundedWindow… | exception | error | solace, java, beam, writer, window |
| The --sdk_location option was used with an unsupported type… | validation | error | python, cli, config, sdk-staging, beam |
| TODO: Add support for reading the timestamp from the… | exception | error | java, beam, windows, unsupported |
| Transform " " was applied to the output of an object of… | exception | error | python, apache-beam, type-check, null-input |
| TryEqualsFloat failed | panic | error | go, beam, passert, testing, panic |
| Unable to parse binary URL | validation | error | url, configuration, prism |
| Unable to read data | exception | error | hadoop, recordreader, illegal-state, current |
| unable to unmarshal TestStreamPayload for | exception | error | go, protobuf, beam-prism, teststream, deserialization |
| Unknown key part | validation | error | java, apache-beam, spanner, type-mismatch |
| Unsupported row type | exception | error | java, iceberg, beam, nested-struct, type-mismatch |
| You must include a descriptorPath or a proto Schema but not… | validation | error | |
| Attempting to create a table with unexpected Calcite Schema… | validation | error | sql, ddl, internal-error |
| Batch does not have expected dtype | validation | error | apache-beam, pytorch, dtype, type-check |
| Can't convert 'null' to FieldType | exception | error | avro, beam, schema-conversion, null-type |
| Cannot deserialize from a JSON string: . | exception | error | java, bigquery, json-deserialization, jackson |
| Cannot find a matching Beam FieldType for Calcite type: | exception | error | beam-sql, calcite, schema, type-mapping |
| Could not encode elements from | console | warning | java, apache-beam, data-sampling, coder |
| could not unmarshal window coder for timer | exception | error | go, apache-beam, coder, windowing |
| {element} | exception | error | python, apache-beam, overflow, int64, combiner |
| error getting last modified time for | exception | error | filesystem, metadata, gcs, last-modified, beam-io |
| Missing input for transform | validation | error | python, apache-beam, pipeline-validation, windowing |
| Missing output value in method | validation | error | go, apache-beam, splittable-dofn, process-continuation |
| Missing type specification in | exception | error | python, apache-beam, yaml, validation |
| OffsetRestrictionTracker is not done since work in range | validation | error | apache-beam, python, splittable-dofn |
| Only strings allowd as map keys when converting from JSON… | exception | error | python, apache-beam, json, type-mismatch |
| Output stream must be writable | validation | error | python, io, bigquery, writer |
| Property "version" not found in… | exception | error | apache-beam, spark, jar, packaging |
| Pub/Sub schema type is not supported at this time | exception | error | java, pubsub, schema, unsupported, avro |
| Received an empty value for non-nullable Snowflake field | validation | error | java, snowflake, schema, nullability |
| requires an input Schema. Note that only Row or user… | validation | critical | java, beam-io, csv, schema |
| [ ] is not supported in AVG | exception | error | beam-sql, unsupported-type, aggregation, java |
| Service failed to start up with error | exception | error | python, subprocess, grpc, startup-failure, apache-beam |
| ShardedKey type-constraint violated. Valid object instance… | validation | error | python, apache-beam, type-hints, runtime-validation |
| Testing the truth value of a deferred scalar is not… | exception | error | python, apache-beam, dataframe-api, deferred |
| the function is not supported for now | exception | error | java, nfa, cep, operator, unsupported |
| unable to decode array with iterable marker | validation | error | go, apache-beam, decoding, iterable, coder |
| Unexpected join type | exception | error | sql, join, internal-error, invariant |
| Unexpected StandardResolveOptions | exception | error | azure, blobstore, resolve-options, unsupported |
| Unrecognized atomic_type | validation | error | python, schema, protobuf, decoding |
| Unsupported Beam logical type | exception | error | java, iceberg, logical-type, type-conversion |
| Unsupported Beam type for Iceberg timestamp with timezone | exception | error | java, iceberg, beam, type-mismatch, datetime |
| Unsupported cell value type | exception | error | bigtable, schema, unsupported-type, java |
| unsupported time policy | panic | error | go, apache-beam, nats, panic, unsupported-policy |
| Value mutated illegally, new value was . Encoding was , now… | exception | critical | java, immutability, coders |
| WriteSimpleRowHeader a 0 length nils bit field | exception | error | go, beam, serialization, row-coder, io |
| A schema is required to write non-schema'd data. | validation | error | python, apache-beam, io, parquet, schema |
| Ambiguous renaming of tags. | exception | error | external-transform, tags, cross-language |
| API Key is required for writing events. | validation | critical | java, beam-io, datadog, api-key, authentication |
| cannot claim a position lower than the previously claimed… | exception | error | go, apache-beam, restriction-tracker, monotonic-progress |
| 'Cannot provide coder for | exception | error | python, coders, typehints, serialization |
| Cannot resolve artifact information | exception | error | java, apache-beam, artifact-staging, portable-pipeline |
| cannot use option zone with workerRegion; prefer either… | validation | error | dataflow, gcp, configuration, flags |
| Environment option ' ' must be set for process environment. | validation | error | java, apache-beam, environment, process-environment |
| Error parsing deferred artifact payload. | exception | error | java, apache-beam, protobuf, artifact-staging |
| error retrieving metadata | exception | error | nats, jetstream, metadata, protocol |
| Failed assert: window | exception | error | python, apache-beam, assertion, windowing, test |