apache/beam
Documented errors, page 3 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Pipeline construction environment and pipeline runtime… | exception | critical | apache-beam, python, environment-mismatch, container-image |
| type-constraint violated. Valid object instance must be of… | validation | error | python, apache-beam, typehints, type-error |
| SortValues requires the secondary key-value pairs to use… | exception | error | apache-beam, coder, java, sort |
| Unexpected IOException: | exception | error | java, apache-beam, coder, runtime-exception |
| Unknown delete file content | exception | error | iceberg, cdc, unsupported-delete-file, version-compatibility |
| bad encoding function | exception | error | go, beam, coder, serialization |
| bad payload for env | exception | error | dataflow, protobuf, pipeline-translation, xlang |
| Cannot convert Beam logical type: to BigQuery type. | validation | error | bigquery, beam-schema, logical-type, type-mapping |
| Datastore total statistics unavailable | exception | error | gcp, datastore, statistics, empty-result, bigquery-io |
| expected row values, but had | exception | error | go, sql, insert, arity-mismatch |
| private key cannot be null | exception | error | java, bigtable, credentials, keystore |
| Problems while retrieving application default credentials. | exception | error | java, gcp, authentication, aws-s3-oidc |
| Unable to convert to a Beam schema. | validation | error | python, apache-beam, avro, schema, conversion |
| unable to infer CombineFn accumulator coder | exception | error | go, beam, combine, coder-inference |
| Unrecognized ' ' position to create shard filter with | validation | error | kinesis, invalid-enum-value, configuration |
| BigQuery data contained value | exception | error | java, beam, bigquery, timestamp, precision |
| Logging stream terminated unexpectedly with success before… | exception | error | grpc, logging, streaming, beam |
| Provided class should be source or sink plugin | exception | error | java, cdap, beam, illegal-argument, plugin-type |
| Saw topic in v1beta1 format. Topics should be in the… | console | warning | java, pubsub, deprecated, naming |
| Unable to generate coder for schema | exception | error | java, beam, schema, reflection |
| Attempting to 'USE CATALOG | validation | error | sql, calcite, catalog, beam |
| f'Unknown transform at line | validation | error | |
| must override get_checkpoint_mark_coder() to return a Coder… | exception | error | apache-beam, python, abstract-method, streaming-source, checkpointing, coder |
| UnboundedReader must override getCurrentRecordOffset() if… | exception | error | java, apache-beam, io, unbounded-source, dedup |
| unexpected SHA256 for sent chunks for | validation | error | checksum, sha256, integrity, artifact-staging, go, beam |
| Could not decode avro record from given bytes | exception | error | avro, beam, deserialization, java |
| Pipeline failed for unknown reason | exception | error | java, beam, apache-beam-sql, pipeline-execution, root-cause-suppressed |
| Unexpected timeout waiting for element future to resolve… | exception | error | java, bigtable, sink, timeout, concurrency |
| Combine.GroupedValues requires its input to use KvCoder | exception | error | java, apache-beam, combine, coder |
| Could not compile CalcFn | exception | error | java, apache-beam, sql, codegen, compilation |
| Error instantiating logical type | exception | error | java, reflection, logical-type, deserialization |
| Indexing a series with key of type | exception | error | apache-beam, dataframe, pandas, indexing, type-mismatch |
| Override this function to provide the default value. | exception | error | java, apache-beam, combine, unsupported-operation |
| "Please run python -m apache_beam.yaml.generate_yaml_docs… | exception | error | |
| SqlTransform can only be applied to schema'd transforms… | exception | error | sql, schema, coder, pipeline-build |
| The PCollection tuple bodies must have the… | validation | error | java, fhir, healthcare, pcollection-tuple |
| Unable to find UserCodeException.wrap | exception | error | java, reflection, classpath, security, apache-beam |
| Unable to generate a getter for getter | exception | error | protobuf, beam, byte-buddy, reflection |
| A cannot be expanded | exception | error | java, beam, runner, pvalue, unsupported |
| bad channel direction | exception | warning | go, apache-beam, serialization, internal-invariant |
| Distinct does not support merging windowing strategies… | exception | error | apache-beam, java, windowing, unsupported-operation |
| Element type must be compatible with Beam Schemas… | validation | error | python, apache-beam, pandas, schemas, batching |
| f'Test specification must be an object, got | validation | error | python, apache-beam, yaml, testing, type-error |
| Impossible state: missing 'apply' method entirely | exception | error | java, reflection, apache-beam |
| Invalid Scope | panic | critical | go, apache-beam, panic, scope |
| str(e) | exception | error | aws, s3, boto3, network, http |
| ValidationException | validation | error | java, cdap, validation, schema, failure-collector |
| Average partition bytes size has not been initialized… | console | warning | java, spanner, changestream, autoscaling |
| Cannot infer schema with a circular reference. Proto Field | exception | error | protobuf, schema-inference, java, recursion |
| Encountered an error when retrieving a configuration | validation | error | java, apache-beam, managed-api, config |
| k_val | exception | error | python, apache-beam, dataframe, keyerror |
| PubSub source descriptor must be in the form "projects/ | validation | error | google-cloud-pubsub, python, validation, apache-beam |
| Unable to subscribe to | exception | critical | java, pubsub, network, authentication |
| Unsupported Beam field type | validation | error | snowflake, apache-beam, schema-mapping, unsupported-type |
| All workers communicate through gRPC should have worker_id… | exception | error | grpc, worker-lifecycle, metadata, beam |
| cannot make schema decoder for type | exception | error | schema-decoder, unexported-embedded-field, reflection, row-encoding |
| DoFn %r has a TimerSpec without an associated on_timer… | validation | error | python, apache-beam, timers, missing-callback, validation |
| failed to create artifact role payload | exception | error | go, protobuf, serialization, beam-artifacts |
| field was received -- type mismatch | validation | error | java, beam-io, csv, type-mismatch, data-quality |
| does not support non zero terminator values. Received… | exception | error | java, apache-beam, coders, decoding, stream-corruption |
| to_runner_api_parameter not implemented for type | exception | error | python, apache-beam, runner-api, serialization |
| Unable to insert job | exception | error | bigquery, gcp, retry-exhausted, job-insert |
| bigqueryio: query parameter | exception | error | bigquery, query-parameters, gob, go |
| broken stream | panic | critical | go, apache-beam, stream, panic |
| Error search FHIR resources writing to Dead Letter Queue. | console | warning | gcp-healthcare, fhir, search, dead-letter |
| Failed to create subscription to topic | exception | critical | java, pubsub, permissions, gcp |
| mismatched output type in method | validation | error | go, apache-beam, dofn, type-mismatch, watermark |
| Protocol Buffers message | exception | error | protobuf, determinism, coder, java |
| Unable to find BigQuery job | exception | error | bigquery, gcp, retry-exhausted, job-polling |
| cannot call getPipelineOptions() in a window-only context | exception | error | apache-beam, state-api, illegal-argument |
| Invalid BigQuery table name | validation | error | bigquery, python, validation, naming |
| Keyword arguments cannot be specified twice. | exception | error | arguments, python-interop, api-misuse |
| missing side input info for collection | exception | error | beam-go, translation, side-input, pipeline-proto |
| No such stream | exception | error | java, bigquery, test-harness, stream-not-found |
| Unable to determine accumulator coder for | exception | error | apache-beam, coders, combinefn |
| Unable to get latest schema metadata for subject: | exception | error | kafka, schema-registry, network |
| cannot register Coder : method named 'of' with arguments… | exception | error | java, reflection, security, coders, apache-beam |
| Creating CustomCoder for type failed | panic | critical | go, beam, panic, coder-registry, invariant |
| failed to connect to control service | exception | critical | network, grpc, beam-go, rpc, startup |
| Failed to patch table schema. | exception | error | bigquery, storage-write, schema, retry-exhausted, gcp |
| FeastFeatureStore handler requires 'feast' package to be… | validation | error | python, apache-beam, yaml, optional-dependency, feast |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, function-signature |
| instruction no longer processing | exception | error | go, beam, state-management, lifecycle |
| No types found for field | validation | error | apache-beam, python, type-inference, schema |
| Returning a from a ParDo or FlatMap is not allowed. Please… | exception | error | python, apache-beam, pardo, dofn, type-error |
| To write a GlobalWindow unbounded PCollection… | validation | error | apache-beam, python, streaming, windowing, sink |
| Cannot convert to a JSON value. | validation | error | python, type-error, serialization, json, google-cloud |
| [ ] is not supported in MAX | exception | error | beam-sql, unsupported-type, aggregation, java |
| Unexpected write method | exception | error | java, bigquery, apache-beam, invalid-enum |
| ValueKind unsupported in | exception | error | java, apache-beam, dofn, splittable-dofn, unsupported-operation |
| broken invariant: idsFound map is nil, but idsRequired map… | panic | error | go, panic, invariant, code-generation |
| DoFn %r has duplicate | validation | error | python, apache-beam, userstate, dofn-signature, validation |
| Failed to print type | exception | error | java, spanner, protobuf, serialization, data-mapping |
| The accumulators cannot be merged | exception | error | java, beam, sketching, count-min-sketch, merge |
| the class must be subclassed properly to use this method | exception | error | cep, abstract-method, subclassing, beam-sql |
| Unable to deterministically encode non-frozen | exception | error | apache-beam, python, coder, serialization, dataclass |
| Unable to get the Filesystem | exception | error | python, io, filesystem, wrapped-error, initialization |
| errIllegalParametersInMultiMap | validation | error | go, beam, multimap, side-input, function-signature |
| Extra packages were already specified | validation | error | java, builder-pattern, illegal-argument, configuration |
| Failed to parse option for | exception | error | protobuf, schema-options, java, parse-error |