apache/beam
Documented errors, page 20 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Field mode ' ' is not supported (field ' ') | exception | error | datacatalog, schema, field-mode |
| google.protobuf.Any is not supported | exception | error | protobuf, beam, unsupported-type |
| Invalid encoded string length | exception | error | java, beam, coder, deserialization, corrupt-data |
| Length of Schema.Field | exception | error | jdbc, beam, schema, validation |
| Message is larger than the max size supported by the coder | exception | error | amqp, coder, message-size, serialization |
| Method Not Allowed | http | warning | http, method-not-allowed, rest |
| NewSK: keyCoder must not be nil | panic | error | go, apache-beam, coder, nil-check, sharded-key |
| non-UTF8 compliant string found | validation | error | go, utf8, data-validation, pipeline |
| Not a valid TFRecord. Mismatch of data mask | validation | error | python, beam, tfrecord, corruption |
| position claimed is out of bounds of the restriction | exception | error | go, apache-beam, restriction-tracker, out-of-bounds |
| snowPipe is required for streaming writes. | validation | error | java, snowflake, streaming, configuration |
| Something went wrong | exception | error | bigtable, changestream, io, missing-parameter |
| source failed processing timers | error_code | error | beam, go, timers |
| timestamp_policy should be one of [ProcessingTime… | validation | error | apache-beam, python, kafka, invalid-enum-value, timestamp-policy |
| Unable to infer coder for output of parseFn. Specify it… | exception | error | java, parquet, apache-beam, coder-inference |
| You are submitting a pipeline with Apache Beam Python SDK | validation | error | python, apache-beam, dataflow, dev-sdk, pipeline-options |
| A 'datagen' table requires either 'rows-per-second' (for… | validation | error | java, beam-sql, datagen, configuration |
| Can't represent as | validation | error | java, avro, beam-schema, datetime, conversion |
| cannot convert schema field | exception | error | go, apache-beam, schema, type-conversion |
| cannot encode a null T-Digest sketch | exception | error | java, beam, coder, null, tdigest, serialization |
| Could convert schema for | validation | error | bigquery, schema, java |
| could not extract body from execute bundles response | error_code | error | go, fhirio, http-response |
| f'Ambiguous output at line | validation | error | yaml, beam-yaml, pipeline-definition, ambiguity |
| failed getGroup for | error_code | error | go, beam, direct-runner, gbk, windowing |
| Failed to get oneof from proto. oneof | exception | error | protobuf, beam, oneof, exception-wrap |
| failed to marshal Nullable coder | exception | error | beam, go, coder, nullable |
| Illegal shard number | validation | error | beam, io, sharding, index-out-of-range |
| Init hooks have already run. Register type during init()… | panic | error | go, apache-beam, registration, reflection, panic |
| Lazily observed byte size will be under reported due to… | console | warning | java, apache-beam, state, metrics |
| Method should not have return type StaticValueProvider, use… | exception | error | java, apache-beam, pipeline-options, valueprovider, api-misuse |
| Model Handler does not implement a default preprocess… | validation | error | python, apache-beam, yaml-ml, preprocessing |
| Painless scripts are not supported on Elasticsearch… | console | error | |
| ProcessElement uses a StateProvider, but is not keyed. All… | validation | error | go, apache-beam, dofn, state, keyed-input |
| ReadSimpleRowHeader field count mismatch, got | exception | error | go, beam, serialization, row-coder, schema-mismatch |
| ReadSimpleRowHeader field count | exception | error | go, beam, serialization, row-coder, corruption |
| Received message missing ackId | exception | error | java, pubsub, gcp, api-response, internal |
| RecordDeltaTaskWriter received unsorted input: a record's… | exception | error | iceberg, cdc, input-ordering |
| Return value not iterable | validation | error | python, apache-beam, type-hints, valueerror |
| set_index with Index or Series instances is not yet… | exception | error | python, apache-beam, dataframe, set-index, not-implemented |
| Should not call getContinuationTrigger | exception | error | java, apache-beam, triggers, watermark, unsupported-operation |
| structx: InferFieldNames of non-struct type | panic | error | go, panic, reflection, structx |
| The partitions and have no overlap | exception | error | bigtable, changestream, partition, range-overlap |
| The requested file doesn't exist. | exception | error | azure, blob-storage, file-not-found, io, container |
| Unable to get BigQuery response after retrying | exception | error | java, gcp, bigquery, retry, dataset |
| Unexpected Beam type | exception | error | java, beam, iceberg, cdc, type-mismatch |
| Unexpected error while serializing PubsubMessage to a byte… | exception | error | java, pubsub, protobuf, serialization, internal |
| Unexpected field type | exception | error | java, apache-beam, schemas, row-processing |
| unexpected inbound type | exception | error | go, type-binding, composite-type |
| Unknown File Format | exception | error | java, iceberg, beam, file-format, configuration, null |
| Unknown WindowInto option type: %T | panic | error | go, panic, windowing, invalid-option |
| Artifact locations are currently supported for only… | exception | error | python, unsupported-path, artifact-location |
| Bad tuple arguments for | validation | error | python, type-hints, apache-beam |
| : closing producer after unrecoverable error. The work… | console | error | kafka, transactions, exactly-once, producer, beam-io |
| Control channel closed. | console | warning | typescript, grpc, stream, worker |
| Could not find a SchemaTransform with identifier | exception | error | java, beam, internal-state |
| error in extractJar() | exception | error | go, zip, jar-extraction, file-system |
| Error mapping Neo4J result | exception | error | java, neo4j, apache-beam, row-mapping |
| failed to initialise Spanner client | exception | critical | gcp, spanner, client-init, network, credentials |
| internal: log message buffer closed | exception | warning | go, apache-beam, harness, logging, channel |
| job failed to prepare | error_code | error | go, beam, grpc, job-submission |
| mismatched Flatten input types | exception | error | beam-go, flatten, type-mismatch, graph-construction |
| Null values are not supported | exception | error | java, beam, null-value, kwargs, cross-language |
| Only INT64 is supported as the interval value for BigQuery. | exception | error | beam-sql, bigquery, interval, type-mismatch |
| Options say to use higher bit type, but that is impossible… | exception | error | java, sbe, invalid-configuration, integer-overflow |
| expects a single tagged PCollection input | validation | error | java, beam, schema-transform, argument-validation |
| SlidingWindows WindowingStrategies must have 0 <= offset <… | validation | error | java, apache-beam, windowing, argument-validation |
| sort_values(axis=index) is not supported because it imposes… | exception | error | apache-beam, dataframe, pandas, sort, order-sensitive |
| Tuple-like arrays are unsupported. Expected a single item… | exception | error | java, json-schema, schemas, arrays |
| Unexpected expansion service address. Expected to be in the… | validation | error | java, beam, address-format, expansion-service, illegal-argument |
| Unsupported atomic type | validation | error | python, schema, protobuf, type-mapping |
| Waiting for timeout check to complete | console | warning | sqs, shutdown, timeout, batch-write |
| An unsupported type of cache was passed in. Received | exception | error | apache-beam, java, fn-harness, cache, type-cast |
| bad function type | exception | error | go, beam, dofn, serialization |
| Class is not registered | exception | error | java, beam, kryo, serialization, class-registration |
| Duplicate values for | exception | error | java, apache-beam, immutable-collection, side-input, unsupported-operation |
| error copying object | exception | error | aws, s3, network, storage |
| Expected chunk to contain embedding. | exception | error | python, postgres, rag, missing-embedding |
| Expected object type, got | validation | error | python, apache-beam, json-schema, schema |
| f"Error loading providers from | exception | error | yaml, python, apache-beam, provider-config, file-not-found |
| forceLpCoders: coder | exception | error | beam, go, prism-runner, coders, test-stream |
| fraction must be between 0 and 1 | validation | error | go, apache-beam, mongodb, split-fraction, validation |
| Mutation type cannot be null. | validation | error | gcp, bigtable, null, mutation |
| passert.Sum( ) = , want | exception | error | testing, assertion, sum, apache-beam |
| Per element sleep time must be at least 1e-3 after being… | validation | error | value-out-of-range, synthetic-pipeline, fanout |
| Stream has been finished. Can not add any more elements. | exception | error | java, apache-beam, io, stream |
| Text is only available for records with payload type TEXT. | exception | error | solace, java, payload-type, state, record |
| The 'google-cloud-pubsub' library is required for… | exception | error | dependency, pubsub, import-error, python |
| The Kafka Streams runner is experimental and is not part of… | exception | error | kafka, build, missing-dependency, experimental |
| too few params | validation | error | go, beam, graph, arity-mismatch |
| Too many requests to Kinesis. Wait some time and retry. | exception | warning | kinesis, throttling, rate-limit, retry |
| unable to convert row type | exception | error | go, beam, schema, row-type |
| Unable to translate | exception | error | python, apache-beam, runner-api, serialization |
| Unknown window function | exception | warning | sql, windowing, explain, beam |
| `UnknownCoderWrapper` was used to perform an actual… | exception | critical | cross-language, coder, deserialization, java, portability |
| Unsupported format for BigQuery table path | validation | error | apache-beam, bigquery, datacatalog, java |
| BeamRowMapper does not have support for fields of type | exception | error | jdbc, beam, schema, type-conversion |
| Cannot call #run(Pipeline) on an instance of | exception | critical | apache-beam, pipeline-runner, configuration, directrunner |
| Cannot outputWithTimestamp from SplitRestriction | exception | error | apache-beam, splittable-dofn, unsupported-operation |
| Cannot provide a coder for wildcard type | exception | error | java, apache-beam, generics, wildcard |
| cross_product must be specified true or false when… | validation | error | yaml, beam-yaml, config, flatmap |