ErrLookup › apache/beam
apache/beam
Apache Beam is a unified programming model for Batch and Streaming data processing. · Java · 5,758 source files
Analyzed at 12126d8942 on 2026-09-13. 4874 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| errIllegalParametersInIter | validation | error | go, beam, side-input, function-signature, reflection |
| Unable to infer the types of | panic | critical | go, apache-beam, panics, generics, type-inference |
| Converting BigQuery type to Beam type is unsupported | exception | error | bigquery, beam, schema-conversion, unsupported-enum, timestamp |
| SideInput unsupported in | exception | error | apache-beam, java, unsupported-operation, side-input, dofn |
| The beam_sql magic tries to query PCollections from… | validation | error | python, apache-beam, interactive, sql, value-error |
| Both a BigQuery table and a query were specified. Please… | validation | error | python, apache-beam, bigquery, configuration, mutually-exclusive |
| User query might have a limit already set, so trying… | console | warning | gcp-datastore, gql, query-limit, beam-io |
| A cluster_identifier should be Optional[Union[str… | validation | error | python, apache-beam, interactive, type-error, dataproc |
| Unable to construct @OnTimer invoker for | exception | error | java, reflection, bytecode, timers, apache-beam |
| Not a primitive type for field name | exception | error | java, apache-beam, schema, row |
| errIllegalParametersInEmit | validation | error | go, apache-beam, emitter, dofn-signature, reflection |
| error when invoking Coder factory method | exception | error | java, reflection, coders, apache-beam |
| Subclasses must implement get_splitter_transform | exception | error | python, apache-beam, abstract-method, rag, chunking |
| Failed to optimize CreateAccumulator for combiner | panic | error | go, apache-beam, combiner, type-inference, panic |
| Invalid signature for | panic | critical | go, apache-beam, panics, function-signature, reflection |
| Could not create a temporary directory for storing… | exception | error | java, io, filesystem, directory-creation |
| Can't convert 'null' to non-nullable field | validation | error | avro, beam, nullability, schema-conversion, illegal-argument |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, panic, function-signature |
| str(e) (wrapped S3 client error message) | exception | error | aws, s3, boto3, network, http |
| Cannot access fire timestamp outside of @OnTimer method. | exception | error | java, apache-beam, timers, unsupported-operation, dofn |
| Reference source must produce the same number of records as… | validation | error | apache-beam, bounded-source, record-count-mismatch, io-testing |
| Internal error determining boundedness of Read | exception | error | java, beam, internal, protobuf, read-transform |
| batch.groupIntoBatchesFn: unexpected timer family | panic | error | go, apache-beam, timer, panic |
| It is required to set useCursorFetch=true in the JDBC URL… | validation | error | jdbc, mysql, beam, configuration |
| Stop position %r did not change after a successful split of… | validation | error | apache-beam, range-tracker, dynamic-splitting, state-mutation |
| TimerFamily unsupported in | exception | error | apache-beam, java, unsupported-operation, timers, dofn |
| Value of class is not a supported type for logical type (… | validation | error | avro, beam, logical-type, type-mismatch, conversion |
| is not an apache_beam.pvalue.PCollection. | validation | error | python, apache-beam, interactive, type-error, argument-validation |
| Could not decode the default value with the provided coder | validation | error | beam, coder, serialization, side-input |
| Expected split of source %r at fraction %r to be successful… | validation | error | apache-beam, range-tracker, dynamic-splitting, expected-outcome-mismatch |
| partitionFn( ) = , want | validation | error | go, apache-beam, partition, value-out-of-range |
| After a successful split, the stop position of the… | validation | error | apache-beam, range-tracker, dynamic-splitting, contract-violation |
| Unable to generate a setter for setter | exception | error | java, reflection, schemas, code-generation |
| ApproximateUnique.PerKey needs an estimation error between… | validation | error | java, apache-beam, illegal-argument, pipeline-construction |
| Joining unbounded PCollections is currently only supported… | exception | error | java, beam-sql, streaming, trigger, windowing, join |
| No code generation strategy available | exception | error | java, reflection, bytebuddy, jpms, classloading |
| Failed to locate DefaultGetSize.validateSize() | exception | critical | java, reflection, classpath, apache-beam, bytecode |
| failed to send chunks for | exception | error | grpc, streaming, artifact-staging, network, go, beam |
| The other object should be an instance of CEPLiteral | exception | error | java, cep, sql, comparable, type-mismatch |
| f' of test specification must be a list, got | validation | error | |
| Unable to access MODEL$ field in SpecificRecordBase class | validation | error | avro, beam, reflection, version-conflict, specificrecord |
| UnboundedSource restriction was neither finished nor… | validation | error | python, apache-beam, streaming, splittable-dofn |
| bad encode | exception | error | go, beam, custom-coder, reflection |
| error in startAutomatedPythonExpansionService | exception | error | go, subprocess, expansion-service, cross-language |
| Timestamp unsupported in | exception | error | apache-beam, java, unsupported-operation, timestamps, dofn |
| Provided coders for type arguments of | exception | error | java, apache-beam, coders, type-mismatch |
| Failed to convert PipelineOptions to JSON | exception | error | java, beam, serialization, protobuf, pipeline-options |
| InvalidTableException(e.getMessage()) | exception | error | |
| query cannot be empty | validation | error | python, apache-beam, datastore, gcp, validation |
| RecordOffset unsupported in | exception | error | java, apache-beam, dofn, splittable-dofn, unsupported-operation |
| Encountered a problem fetching table | exception | error | java, iceberg, cache, beam |
| ApproximateUnique.PerKey requires its input to use KvCoder | exception | error | java, apache-beam, coder, pipeline-construction |
| Could not find coder for URN " + urn | exception | error | python, apache-beam, cross-language, expansion-service, managed-transform |
| Expected state to be STARTED, but was COMPLETE_ERROR | exception | error | java, firestore, state-machine, rpc |
| Failed to optimize MergeAccumulators for combiner | panic | critical | go, apache-beam, panics, generics, combiner |
| Unexpected composite type | panic | error | go, apache-beam, coder, panic, type-inference |
| the right side CEP operation is not legal | exception | error | sql, cep, pattern-matching, unsupported |
| Unsupported Beam field type | validation | error | snowflake, apache-beam, schema-mapping, decimal |
| Encountered an error when creating a RecordWriter for table | exception | error | iceberg, java, file-io, writer, apache-beam |
| Failed to optimize AddInput for combiner | panic | error | go, beam, combiner, codegen |
| unable to convert value of | exception | error | go, apache-beam, schema, type-conversion |
| CausedByDrain unsupported in | exception | error | java, apache-beam, dofn, timers, drain, unsupported-operation |
| Schema element unsupported in | exception | error | apache-beam, java, unsupported-operation, schema, dofn |
| calling getSideInput() with unknown view | exception | error | java, beam, side-input, splittable-pardo, dofn |
| CheckpointMark must override getOffsetLimit() if… | exception | error | java, apache-beam, io, unbounded-source, dedup |
| Found multiple SchemaTransforms with the name | validation | error | |
| List operation failed | exception | error | python, apache-beam, filesystem, glob, listing |
| The --temp_location option must be specified. | validation | error | dataflow, configuration, gcs, temp-location |
| prism error building stage | exception | error | go, beam, prism-runner, stage-build |
| Unable to generate a creator for POJO | exception | error | java, beam-schema, pojo, reflection, constructor |
| invalid schema type | panic | critical | bigquery, schema, go, apache-beam |
| Converting BigQuery type '' to '' is not supported | exception | error | java, apache-beam, bigquery, unsupported-type, conversion |
| Not all temporary files are present for importing. | exception | error | java, fhir, gcs, import, file-not-found |
| Could not override the transforms with URNs | exception | error | java, beam, pipeline-translation, transform-service, upgrade |
| invalid incremental, inc value must be within | validation | error | mongodb, objectid, value-out-of-range |
| The requesting owner must be registered. | exception | error | python, state, resource-lifecycle, apache-beam |
| Unable to claim position | exception | error | apache-beam, python, io, range-tracker, tfrecord |
| Unable to derive type for ValueProvider | exception | error | jackson, deserialization, generics, pipeline-options |
| Cannot import as . | console | warning | serialization, import, portability, callable |
| Writing of MAP type is not supported by the default… | exception | error | java, beam, singlestore, write, map |
| A BigQuery table or a query must be specified | validation | error | python, apache-beam, bigquery, missing-argument |
| decoding time.Time schema override | exception | error | beam, decoding, schema, serialization |
| Unable to construct @OnTimerFamily invoker for | exception | error | java, reflection, bytecode, timers, apache-beam |
| unable to get Spanner instanceConfigId for | console | warning | java, spanner, gcp, instance-config |
| No MLTransform found. Please install tensorflow-transform… | validation | error | python, apache-beam, yaml, ml, missing-dependency |
| e | exception | error | java, apache-beam, firestore, data-conversion, pipeline-failure |
| : unable to decode , encoding of value , using | exception | error | beam, coder, serialization, round-trip |
| Failed to get table with | console | error | bigquery, api, network, permissions |
| The PCollection tuple must have the… | validation | error | java, dicom, healthcare, pcollection-tuple |
| Unknown implementation of Type | exception | error | java, apache-beam, reflection, api-surface |
| databaseId can't be empty | validation | error | java, apache-beam, google-cloud-spanner, validation |
| expecting type to have arity , had arity instead | validation | error | python, apache-beam, type-hints, typing |
| failed to matched a field for SQL column | exception | error | go, reflection, sql, schema-mapping |
| No type registered | validation | error | go, datastore, type-registry, serialization |
| The PCollection tuple must have the… | validation | error | java, apache-beam, google-cloud-healthcare, pcollectiontuple, illegal-argument |
| Error while parsing input element | console | warning | java, schema, serialization, beam |
| langchain is required to use LangChainChunkerPlease install… | exception | error | python, apache-beam, importerror, langchain, optional-dependency |
| PCollection not available, please run the pipeline. | exception | error | python, apache-beam, interactive, cache, state, value-error |
| Unable to convert query | exception | error | sql, query-planning, beam |
| prism error building stage | exception | error | go, beam, teststream, prism-runner |