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. 5177 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| errIllegalParametersInIter | validation | error | go, beam, side-input, function-signature, reflection |
| Unable to infer the types of {{$upperName}} | 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 ${context} | exception | error | apache-beam, java, unsupported-operation, side-input, dofn |
| The beam_sql magic tries to query PCollections from multiple | validation | error | python, apache-beam, interactive, sql, value-error |
| Both a BigQuery table and a query were specified. Please spe | validation | error | python, apache-beam, bigquery, configuration, mutually-exclusive |
| User query might have a limit already set, so trying without | console | warning | gcp-datastore, gql, query-limit, beam-io |
| A cluster_identifier should be Optional[Union[str, beam.Pipe | validation | error | python, apache-beam, interactive, type-error, dataproc |
| Unable to construct @OnTimer invoker for ${className} | exception | error | java, reflection, bytecode, timers, apache-beam |
| Not a primitive type for field name %s: %s | 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 %v. Failed | panic | error | go, apache-beam, combiner, type-inference, panic |
| Invalid signature for {{$upperName}} | panic | critical | go, apache-beam, panics, function-signature, reflection |
| Could not create a temporary directory for storing dependenc | 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 %v with %v inputs and %v ou | 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 %q | panic | error | go, apache-beam, timer, panic |
| It is required to set useCursorFetch=true in the JDBC URL wh | 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 ${context} | exception | error | apache-beam, java, unsupported-operation, timers, dofn |
| Value ${value} of class ${valueClass} is not a supported typ | validation | error | avro, beam, logical-type, type-mismatch, conversion |
| {pcoll} 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(%v) = %v, want [0,%v) | validation | error | go, apache-beam, partition, value-out-of-range |
| After a successful split, the stop position of the RangeTrac | validation | error | apache-beam, range-tracker, dynamic-splitting, contract-violation |
| Unable to generate a setter for setter '%s' | exception | error | java, reflection, schemas, code-generation |
| ApproximateUnique.PerKey needs an estimation error between 1 | validation | error | java, apache-beam, illegal-argument, pipeline-construction |
| Joining unbounded PCollections is currently only supported f | 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 %v; close error: %v | 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'{attr_type} of test specification {identifier} must be a l | validation | error | |
| Failed to optimize CreateAccumulator for combiner %v. Failed | panic | critical | go, apache-beam, panics, generics, combiner |
| Unable to access MODEL$ field in SpecificRecordBase class | validation | error | avro, beam, reflection, version-conflict, specificrecord |
| UnboundedSource restriction was neither finished nor checkpo | validation | error | python, apache-beam, streaming, splittable-dofn |
| bad encode | exception | error | go, beam, custom-coder, reflection |
| error in startAutomatedPythonExpansionService(%s,%s): %w | exception | error | go, subprocess, expansion-service, cross-language |
| Timestamp unsupported in ${context} | exception | error | apache-beam, java, unsupported-operation, timestamps, dofn |
| Provided coders for type arguments of %s contain incompatibi | 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 %s | exception | error | java, apache-beam, dofn, splittable-dofn, unsupported-operation |
| Encountered a problem fetching table {} from cache. | 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 %v. Failed | panic | critical | go, apache-beam, panics, generics, combiner |
| Unexpected composite type: %v | panic | error | go, apache-beam, coder, panic, type-inference |
| the right side CEP operation is not legal: ${class} | exception | error | sql, cep, pattern-matching, unsupported |
| Unsupported Beam field type %s for Snowflake column '%s'. Be | 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 %v. Failed to infer | panic | error | go, beam, combiner, codegen |
| unable to convert value of %v to schema field | exception | error | go, apache-beam, schema, type-conversion |
| CausedByDrain unsupported in %s | exception | error | java, apache-beam, dofn, timers, drain, unsupported-operation |
| Schema element unsupported in ${context} | 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 offset-base | exception | error | java, apache-beam, io, unbounded-source, dedup |
| Found multiple SchemaTransforms with the name '%s': %s | 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 %v: %w | exception | error | go, beam, prism-runner, stage-build |
| Unable to generate a creator for POJO '%s' with inferred sch | exception | error | java, beam-schema, pojo, reflection, constructor |
| invalid schema type: %v | 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 [%s, %s) | 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: %s | exception | error | apache-beam, python, io, range-tracker, tfrecord |
| Unable to derive type for ValueProvider: <type> | exception | error | jackson, deserialization, generics, pipeline-options |
| Cannot import {constructor} as {fully_qualified_name}. | console | warning | serialization, import, portability, callable |
| Writing of MAP type is not supported by the default UserData | 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 ${className} | 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 or | validation | error | python, apache-beam, yaml, ml, missing-dependency |
| e | exception | error | java, apache-beam, firestore, data-conversion, pipeline-failure |
| {errorContext}: unable to decode {encodedValue}, encoding of | exception | error | beam, coder, serialization, round-trip |
| Failed to get table {} with {} | console | error | bigquery, api, network, permissions |
| The PCollection tuple must have the DicomIO.ReadStudyMetadat | 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 %s to have arity %d, had arity %d instead | validation | error | python, apache-beam, type-hints, typing |
| failed to matched a %v field for SQL column: %v | exception | error | go, reflection, sql, schema-mapping |
| No type registered %s | validation | error | go, datastore, type-registry, serialization |
| The PCollection tuple must have the FhirIOPatientEverything. | 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 %s | exception | error | sql, query-planning, beam |