apache/beam
Documented errors, page 27 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| 'elements must be a list of elements' | validation | error | python, apache-beam, yaml, create, type-mismatch |
| Embeddings can only be generated on dict[str, Image].Got… | exception | error | python, type-mismatch, embeddings, image |
| error creating jar packJar | exception | error | go, filesystem, jar |
| error getting object | exception | error | aws, s3, network, file-read |
| error listing object keys | exception | error | aws, s3, network, io |
| ErrorHandler must be finalized before the output can be… | exception | error | java, apache-beam, error-handling, illegal-state, lifecycle |
| Expansion service with target | exception | error | yaml, code-generation, cross-language, missing-field |
| Failed to close multiplexer | console | warning | java, apache-beam, grpc, shutdown |
| Failed to load user-defined scalar function | exception | error | udf, io, classpath, beam |
| failed to stat | exception | error | go, filesystem, stat, beam-artifacts |
| flush on closed file | exception | error | python, apache-beam, bigquery, file-io, avro |
| invalid input pcollection | validation | error | apache-beam, go, windowing, pipeline-construction |
| invalid registration type | panic | error | go, apache-beam, registration, reflection, panic |
| Length of parameters to a Dict type-hint must be exactly 2… | validation | error | python, apache-beam, type-hints, dict |
| lpUnknownCoders: couldn't handle component | exception | critical | beam, go, prism-runner, coders |
| Min and max transformed values were not equal, for column | exception | error | java, iceberg, partitioning, transforms |
| No translator known for | exception | error | java, translation, urn, registration |
| Non-nullable field ' ' is not present in the JSON object. | validation | error | beam, json, schema, deserialization |
| Not implemented yet | exception | error | java, google-bigquery, protobuf, unimplemented |
| NotImplementedError(type(self)) | exception | error | python, apache-beam, rag, abstract-method, vector-db |
| opening a reader on a closed channel. Original error | exception | error | data-channel, closed-channel, state, beam, go |
| Problems while trying to instantiate a dynamic web id token… | exception | error | java, reflection, classpath, aws-oidc |
| Provided size is bigger than max size | validation | error | java, snowflake, schema, validation |
| resp.Error | exception | error | go, apache-beam, state-management, runner |
| Restriction tracker missing. | exception | error | go, apache-beam, sdf, split, checkpoint |
| type-constraint violated. The type of key in 'ShardedKey'… | validation | error | python, apache-beam, type-hints, runtime-validation |
| size returned expected to be non-negative but received | error_code | error | go, apache-beam, splittable-dofn, sdf |
| Unable to abort task | exception | error | hadoop, outputcommitter, abort, sink |
| Unable to deterministically order keys of dict for | exception | error | python, coder, determinism, dict, typeerror |
| unable to open file | exception | error | go, beam, file-io, artifact-staging |
| Unexpected input element type | exception | error | apache-beam, protobuf, version-skew |
| Unknown language for | exception | error | python, apache-beam, yaml, language, provider |
| Unsupported TimeDomain: %r. | validation | error | python, apache-beam, timers, time-domain, invalid-value |
| Value translation's input type is not same as hadoop… | validation | error | java, beam, type-mismatch, hadoop-inputformat |
| You must specify a --job_endpoint when using… | validation | error | configuration, portable-runner, missing-endpoint |
| BoundedWindow unsupported in | exception | error | apache-beam, java, unsupported-operation, windowing |
| Combine requires CoGBK type | exception | error | beam-go, combine, cogbk, graph-construction |
| CombineFn.setup and CombineFn.teardown are not supported… | validation | error | python, apache-beam, dataflow, combinefn, runner-v2 |
| Could not parse the provided allowlist file | exception | error | java, file, io, allowlist |
| Dependencies must be a list of strings, got | exception | error | python, apache-beam, yaml, typeerror, dependencies |
| DoFn.WatermarkEstimatorParam… | validation | error | apache-beam, dofn, watermark, type-check |
| dt not in UTC | validation | error | python, value-error, datetime, timezone |
| Either Query or Table must be specified. | validation | error | jdbc, java, validation, configuration |
| error getting metadata for object | exception | error | aws, s3, network, metadata |
| Expected state to be STARTED, but was COMPLETE_SUCCESS | exception | error | firestore, qos, illegal-state, lifecycle, java, apache-beam |
| failed to add input kind | exception | error | go, apache-beam, marshalling, edge |
| Failed to build package from | exception | error | python, apache-beam, packaging, build |
| Failed to read PipelineOptions from JSON | exception | error | java, apache-beam, pipeline-options, json |
| GcsSeekableByteChannel are read-only and does not support… | exception | error | gcs, java, unsupported-operation, read-only |
| Inputs to Flatten had incompatible triggers | exception | error | java, apache-beam, windowing, triggers, flatten |
| Invalid host/port in BigtableConfig | exception | error | bigtable, config, emulator, port |
| invalid key pattern | validation | error | s3, glob, pattern, validation |
| Invalid number of components for ShardedKey | panic | error | go, apache-beam, typex, panic, arity-mismatch |
| Make sure the values passed in `where_clause_fields` are… | exception | error | python, cloudsql, apache-beam, schema |
| No SerializeToString method is detected on loaded model… | exception | error | python, apache-beam, onnx, type-error, serialization |
| Reshuffle input type cannot be CoGBK | exception | error | beam-go, reshuffle, cogbk, unsupported-type |
| Row OutputReceiver unsupported in | exception | error | apache-beam, java, unsupported-operation, schema |
| : gcs_location must be of type string or ValueProvider; got… | validation | error | python, apache-beam, bigquery, type-error |
| SQL Server does not support connectionInitSql. | validation | error | jdbc, sqlserver, beam, configuration |
| Table : . not found but create disposition is CREATE_NEVER. | exception | error | bigquery, python, gcp, disposition |
| The number of elements in the provided pre-timestamped data… | validation | error | python, apache-beam, timestamps |
| Timed out waiting for cache file for PCollection | exception | error | apache-beam, interactive-beam, cache, timeout, streaming |
| TruncateRestriction has unexpected number of return values | panic | error | go, apache-beam, splittable-dofn, reflection |
| Unable to create the keytab file for the provided secret. | exception | error | java, kafka, kerberos, configuration |
| unexpected number of returns in method | validation | error | go, apache-beam, sdf, signature-validation, reflection |
| Unsupported Union with no arguments. | validation | error | python, type-hints, apache-beam, typing |
| WatermarkHoldState is unsupported by the Fn API. | exception | error | state, unsupported, beam, portability |
| Artifacts not found at location | exception | error | python, apache-beam, artifact-location, file-not-found |
| cannot make schema for type | exception | error | go, beam, schema, reflection, embedded-fields |
| Cannot pickle files that are not opened for reading | exception | error | python, pickle, serialization, file-mode |
| ${diagnostics} | exception | error | java, apache-beam, compilation, udf |
| Either .process_batch() must have a type annotation on its… | validation | error | python, apache-beam, type-annotation, typeerror |
| Error writing to Solr after | exception | error | java, beam, solr, retry, exhausted |
| Exception getting credentials | exception | error | bigtable, credentials, security |
| Expected Document but got " + (converted != null ?… | validation | error | java, apache-beam, mongodb, row-conversion, type-mismatch |
| failed to send header for | exception | error | grpc, streaming, network, artifact |
| failed to stage file | exception | error | artifact-staging, file-not-found, grpc, file-upload |
| GroupIntoBatches | panic | error | go, apache-beam, panic, invalid-params |
| Interrupted while executing batch GCS request | exception | error | gcs, interrupted, concurrency |
| KV coder with more than 2 components | panic | critical | go, beam, prism, coder, panic |
| Map type is not parameterized! | exception | error | java, generics, reflection, beam-schema |
| MatchContinuously stop_timestamp | validation | error | python, apache-beam, io, timestamps |
| Missing output in error_handling of | exception | error | python, apache-beam, yaml, error-handling, validation |
| Missing required value for group | validation | error | java, apache-beam, validation, required-options, dataflow |
| mongodbio.inferProjection: no names to infer projection from | panic | error | go, mongodb, panic, reflection, struct |
| name + " cannot be empty" | validation | error | java, snowflake, validation, configuration |
| Parameter not supported by DoFnTester | exception | error | java, apache-beam, dofn, testing |
| Performing a numeric aggregation | console | warning | python, pandas, dataframe, dtype, beam |
| project cannot be empty, got | validation | error | go, apache-beam, gcs, config, validation |
| [ ] is not supported in SUM | exception | error | beam-sql, unsupported-type, aggregation, java |
| State type not recognized for state | exception | error | go, apache-beam, state, unsupported-type |
| Stream is closed. | exception | error | python, io, closed-stream, lifecycle |
| The copy source does not exist. | exception | error | azure, blob-storage, file-not-found, copy, io |
| unable to decode bool; expected | panic | critical | go, decoding, panic, coder, byte-stream |
| Unable to encode element '" + value + "' with coder '" +… | exception | error | java, beam, coders, encoding |
| unable to start container image | exception | error | go, beam, prism-runner, docker, container |
| Unexpected null for key type: " + fieldDescriptor.getName() | exception | error | java, apache-beam, bigquery, map-type |
| Unexpected status [ ] of load job: . | exception | error | java, bigquery, unexpected-status, illegal-state |
| Unknown mode | exception | error | java, beam, bigquery, schema, enum |
| Unrecognized input type | validation | error | apache-beam, java, yaml-transform, type-mismatch |