apache/beam
Documented errors, page 24 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| failed to get job | error_code | error | go, dataflow, polling, api |
| Ignoring unmatched input fields | console | warning | sqs, schema, mapping, unused-fields |
| Incorrectly sized byte array. | validation | error | java, avro, beam-schema, fixed-bytes, conversion |
| ListBuffer append after read. | exception | error | apache-beam, fn-api-runner, buffer-lifecycle, runtime-error |
| Only SlidingWindows objects with the same size, period and… | exception | error | java, apache-beam, windowing, compatibility |
| Received from DoFn that was expected to produce a batch. | exception | error | python, apache-beam, batched-dofn, type-error |
| Runner does not support draining. | exception | error | java, apache-beam, runner, streaming, unsupported-operation |
| .getSideInputWindow() should never be called. It is a… | exception | error | java, beam, windowing, side-input, unsupported-operation |
| is splittable and uses timer family, but these are not… | exception | error | java, apache-beam, splittable-dofn, timers |
| Schema update load job | console | error | bigquery, load-job, api, permissions |
| short write of data got | exception | error | go, io, code-generation, short-write |
| State stream is closed. | exception | error | beam, worker, state, grpc, lifecycle |
| The Primitive HCat type | exception | error | java, schema, hcatalog, type-mapping |
| Tokens ( , ) not in range of | exception | error | java, cassandra, token-ring, inconsistent-state |
| Unable to copy unequal number of sources and destinations | validation | error | s3, aws, beam-io-error, copy, argument-count |
| unable to encode ParDoPayload for | exception | error | beam, prism, protobuf, marshal |
| Unknown artifact type " +… | exception | error | artifacts, unsupported, version-skew, runner |
| Unknown operation action | exception | error | apache-beam, google-cloud-spanner, dispatch, valueerror |
| Unknown state request | exception | error | state, grpc, version-mismatch, unsupported-feature |
| Unsigned integers are not supported. | exception | error | java, arrow, unsigned-integer, beam-schema |
| You are using version | console | warning | python, pip, installation, version-check |
| Beam has not been initialized. Call beam.Init() before… | panic | error | go, dataflow, initialization |
| BigQuery storage source must be split before reading | exception | error | bigquery, storage-read-api, lifecycle, unsupported-operation |
| Cannot select a subfield of a non-composite type. | exception | error | java, apache-beam, schemas, nested-fields |
| Could not find a way to create AutoValue class | exception | error | autovalue, schema, annotation-processing |
| Could not parse sort modifiers | validation | error | iceberg, illegal-argument, parsing, sort-order |
| Could not resolve table in Data Catalog | exception | error | apache-beam, datacatalog, java, gcp |
| Does not support table_valued function | exception | error | sql, table-valued-function, unsupported, beam-sql |
| emit parameters expected in method | validation | error | go, apache-beam, dofn, emit-functions |
| .exceptionsVia() is required | exception | error | java, apache-beam, pipeline-construction, missing-argument, null-pointer |
| f'Unknown provider type | exception | error | python, apache-beam, yaml, provider, unknown-type |
| Failed to convert PipelineOptions to Protocol | exception | error | java, apache-beam, pipeline-options, jackson, serialization |
| failed to dial server at | exception | error | grpc, network, dial, apache-beam |
| found uses of features unimplemented in prism in job | exception | error | go, beam-prism, unsupported-feature, validation |
| google-cloud-bigquery-storage is required for… | validation | error | python, apache-beam, bigquery, dependency, import |
| Heap dumps are requested with --enableHeapDumps but neither… | console | warning | java, apache-beam, heap-dump, configuration |
| inputs of have different window strategy: VS | exception | error | sql, windows, set-operator, streaming, beam |
| KeepFn must return a boolean, but returns instead. | exception | error | java, apache-beam, filter, type-mismatch |
| Multiple non-side inputs. | exception | error | side-inputs, pardo, direct-runner, validation |
| name not set | exception | warning | java, apache-beam, illegal-state, naming |
| no job service endpoint specified. Use --endpoint= | validation | error | go, cli-flag, configuration |
| Ordering of elements in a set may be non-deterministic. | exception | error | java, beam, coders, determinism |
| (peek) coder with id | exception | error | beam, go, coder, pipeline-model |
| Query and table params are mutually exclusive. Set just one… | validation | error | java, apache-beam, google-cloud-spanner, validation |
| does not support predicate/project push-down, yet non-empty… | exception | error | java, beam-sql, delta-lake, pushdown |
| : the result is expected to be an integer, not None. | validation | error | python, apache-beam, metrics, distribution, load-testing |
| Saw subscription in v1beta1 format. Subscriptions should be… | console | warning | java, pubsub, deprecated, url-format, migration |
| table name has empty components | exception | error | bigquery, parsing, validation, beam-io |
| Transform Service did not start in | exception | error | java, timeout, docker, service-startup |
| Unable to parse process environment config | exception | error | java, apache-beam, json-parse, environment-config |
| Unable to rename a directory. | validation | error | azure, rename, invalid-argument |
| Unexpected getOffsetLimit() called while… | exception | error | kafka, checkpoint, deduplication, beam-io |
| Unexpected type kind | panic | error | go, beam, typex, reflect, unsupported-type |
| Unhandled logical type | exception | error | avro, beam, logical-type, schema-conversion |
| Unknown time domain | validation | error | java, apache-beam, timers |
| Unknown type of encoding context | exception | error | python, apache-beam, schema-transform, discovery, naming |
| Unsupported spanner type | exception | error | spanner, unsupported-type, schema-mapping, java |
| assert_that must be used within a beam.Pipeline context… | exception | error | apache-beam, testing, pipeline-context, assertion |
| AutoValue builder class | exception | error | java, apache-beam, autovalue, reflection |
| bundle size must be greater than 0 | validation | error | go, apache-beam, mongodb, config-validation |
| Can not read value at | exception | error | parquet, decoding, apache-beam, java-io |
| cannot call window() in a null context | exception | error | |
| Columns are not specified. Please specify the column for… | exception | error | python, apache-beam, tft, missing-argument |
| Constructor method needs to be explicitly allowed | exception | error | java, security, allowlist, beam-expansion |
| CreateTracker has unexpected number of return values | panic | error | go, apache-beam, splittable-dofn, interface |
| Dataflow can only execute pipeline steps in Docker… | exception | error | dataflow, docker, environment, cross-language |
| DoFn.process() method-only parameter | validation | error | python, apache-beam, dofn |
| Error Handling is partially supported when using… | console | warning | java, apache-beam, bigquery, error-handling |
| expected 1 option, got | validation | error | configuration, hook, argument-count, beam, go |
| expected WV coder for user state | panic | error | go, apache-beam, coder, panic |
| Failed to initialize cryptography libraries needed for… | exception | critical | apache-beam, java, cryptography, aes-gcm, hmac, initialization |
| failed to match optional parameter | validation | error | go, beam, signature-validation, reflection |
| failed to reverse lookup known function | exception | error | go, runtime, symbols, symtab |
| failed to split at requested splits | exception | error | beam-go, split, nil-check, datasource |
| Flatten needs at least 2 input, got | exception | error | beam-go, flatten, arity, graph-construction |
| GroupIntoBatches: key coder for type | panic | error | go, apache-beam, coder, determinism |
| Incompatible func type: got func | panic | error | go, reflection, arity-mismatch, panic |
| InitialWatermarkEstimatorState fn | error_code | error | go, beam, sdf, watermark, arity |
| need to set the topic of a PubsubIO.Write transform if not… | validation | error | java, pubsub, missing-configuration, pipeline-construction |
| No fields were set for input | exception | error | java, apache-beam, co-group, join |
| Null key | exception | error | bigtable, null, row-key |
| OnTimer function not defined for DoFn | validation | error | go, apache-beam, dofn, timers, method-not-implemented |
| Project and location must both be provided if one is… | validation | error | java, configuration, vertex-ai |
| cannot be made deterministic for ' '. | exception | error | python, apache-beam, determinism, serialization |
| Search strategy must be provided | validation | error | python, apache-beam, milvus, rag, validation |
| side input in method | validation | error | go, apache-beam, dofn, side-input, type-mismatch |
| Table : . requires a schema. None can be inferred because… | exception | error | bigquery, python, gcp, schema |
| too many parameters | validation | error | go, beam, signature-validation, reflection |
| unable to do row encoding | panic | error | beam-go, jdbc, encoding, panic, type-mismatch |
| Unable to parse JSON value | validation | error | java, apache-beam, json, cli, parsing |
| Unable to verify project with ID | exception | error | gcp, project, network, api, java |
| Unknown allow-list version | exception | error | java, beam, allowlist |
| Unknown mutation operation type | validation | error | java, apache-beam, spanner, config |
| Unrecognized uint16 behavior | exception | error | java, sbe, unhandled-switch-case, configuration |
| Unsupported field type: " + fieldType | validation | error | mongodb, apache-beam, schema, unsupported |
| Use () not . | validation | error | python, apache-beam, transform-usage |
| A schema was provided without a data format (or viceversa)… | validation | error | java, apache-beam, pubsub, configuration |
| Any not yet supported | exception | error | protobuf, any, unsupported-type, java |
| bad input type | exception | error | go, beam, serialization, input-kind |
| beam:logical_type:timestamp:v1 requires a precision… | exception | error | python, apache-beam, timestamp, logical-type, precision |