apache/beam
Documented errors, page 4 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Faled loading session: expected dict, got | validation | error | python, apache-beam, deserialization, session |
| FieldType unexpected +fieldType.getTypeName() | exception | error | java, schema, serialization, type-mismatch |
| Numeric aggregation ( ) on a DataFrame containing… | exception | error | pandas, apache-beam, dataframe, aggregation, numeric-only |
| unable to convert map value type | exception | error | go, beam, schema, reflection |
| Bundle is not in a finalizable state for | exception | error | apache-beam, sdk-worker, lifecycle |
| Expected image content in | exception | error | python, apache-beam, valueerror, embeddings, null-content |
| invalid CombineFn | validation | error | beam, go, combinefn, graph-validation |
| Null collectionElementType at column | exception | error | java, bigtable, schema, null |
| offset is negative: | exception | error | java, apache-beam, io, argument-validation |
| ${result.output} | exception | error | |
| Unknown timestamp bound mode: + mode | validation | error | java, apache-beam, google-cloud-spanner, enum |
| Unknown type | validation | error | java, apache-beam, spanner, type-mismatch |
| is not assignable to | exception | error | go, type-binding, dofn-signature |
| Was unable to reset bundle processor safely. Bundle… | console | warning | java, apache-beam, bundle-processor, resource-cleanup |
| WindowFns must match for a… | exception | error | java, beam-sql, windowing, join, streaming |
| bad parameter type for | validation | error | go, beam, funcx, dofn, signature |
| Failed to parse record into proto | exception | error | java, spanner, json, protobuf, data-mapping |
| Null family schema at family | exception | error | java, bigtable, schema, null |
| response contains bad status | http | error | http, fhir, gcp, api-error |
| Unable to convert pipeline options, please check for… | exception | critical | java, apache-beam, jackson, classpath, dependency-conflict |
| bigquery write error | exception | error | bigquery, write, schema, go |
| Cannot encode elements of type | exception | error | java, apache-beam, coders, nested-generics |
| Cannot get Elasticsearch version | exception | error | java, elasticsearch, beam, connectivity |
| Cannot infer coder for type parameter | exception | error | java, apache-beam, coders, generics, type-inference |
| Could not decode Pubsub message | exception | error | java, pubsub, deserialization, coder |
| Error fetching HL7v2 message with ID | console | warning | gcp-healthcare, hl7v2, dead-letter, fetch-error |
| failed to map main input window to side input window with… | exception | error | windowing, side-input, beam, go |
| Given Spark Receiver class | exception | error | apache-beam, java, spark-receiver, pipeline-construction |
| label + ": " + String.format(message, args) | exception | error | java, apache-beam, dofn-signature, illegal-argument |
| method invalid | exception | error | beam-go, reflection, method-signature, dofn |
| number of side inputs in method | validation | error | go, apache-beam, dofn, side-input, signature-validation |
| Please specify InteractiveRunner when creating the Beam… | exception | error | python, apache-beam, interactive, streaming, runtime-error |
| presultErr.Error() | error_code | error | go, dataflow, api, pipeline-result |
| Unknown | exception | error | java, beam, windowing, enum-conversion, proto |
| Could not instantiate deserializers | exception | error | |
| Encountered unexpected value for null indicator | exception | error | python, apache-beam, coding, decoding, data-corruption |
| Expected Map for map field. | validation | error | java, firestore, schema, type-mismatch |
| Export cannot be executed because export URI | exception | error | java, fhir, export, gcs, bigquery, unsupported-uri |
| FinishBundleContext unsupported in | exception | error | java, apache-beam, unsupported-operation, dofn |
| 'items' missing from Elasticsearch response | console | error | elasticsearch, http, malformed-response |
| KafkaWriter : failed to send | exception | error | |
| MergeAccumulators must be defined on accumulator | panic | error | go, beam, combiner, missing-method, panic |
| num_workers ( ) cannot exceed max_num_workers ( ) | validation | error | dataflow, go, configuration, worker-settings |
| is not compatible with | exception | error | java, apache-beam, windowing, type-mismatch |
| Class has no path back to any root class. It should never… | exception | error | java, apache-beam, api-surface, internal-state |
| control.Recv failed | exception | error | network, grpc, beam-go, stream, runtime |
| Failed to read elements from the bounded reader. | exception | critical | io, checkpointing, bounded-source, streaming, java |
| Field expression %r at | validation | error | python, apache-beam, groupby, argument-validation |
| Unable to infer SQL type from type variable . This usually… | exception | error | java, beam-sql, generics, type-erasure, udaf |
| values of cannot bind to | exception | error | go, apache-beam, cogbk, side-input, type-mismatch |
| wrong decoding sequence found. | exception | error | java, coder, deserialization, corrupt-data |
| Datastore statistics for kind | exception | error | gcp, datastore, statistics, entity-not-found, bigquery-io |
| Error when writing batch. | console | error | java, apache-beam, aws, async-write, batch |
| Failed to translate BigtableOptions to BigtableConfig | exception | error | java, bigtable, io, configuration |
| Invalid watermark policy | validation | error | python, apache-beam, kinesis, invalid-enum-value, config-validation |
| panic | panic | critical | go, panic, dofn, pipeline-execution |
| Pillow is required to use HuggingfaceImageEmbeddings… | exception | error | python, apache-beam, importerror, pillow, optional-dependency |
| Query job failed, status | exception | error | bigquery, gcp, query-job, io-exception |
| Requires stateful processing (BEAM-2687) | exception | error | python, apache-beam, streaming, not-implemented, runner-compatibility |
| There are different initial sequences detected | exception | error | apache-beam, combiner, state-corruption, invariant |
| Unsupported logical type " + logicalType.getName() | exception | error | java, bigquery, avro, logical-type |
| generating bundle for stage | panic | critical | go, beam, prism, panic, watermark |
| cannot be empty | validation | error | java, configuration, snowflake, missing-field |
| unable to convert map key type | exception | error | go, apache-beam, schema, map |
| Unsupported precision for Timestamp logical type | validation | error | bigquery, beam, schema-conversion, timestamp-precision, logical-type |
| Unsupported type | exception | error | java, beam-sql, type-conversion, schema |
| invalid coder | validation | error | go, beam, coder, json |
| invalid status for plan | error_code | error | go, apache-beam, lifecycle, state-machine |
| offset: , whence: , position: , last | exception | error | python, io, seek, compressed-stream, not-implemented |
| Special type " " not permitted in concrete types | validation | error | go, apache-beam, type-system |
| The other CEPLiteral should have type , given: | exception | error | java, cep, sql, comparable, sql-type |
| TimerId unsupported in | exception | error | apache-beam, java, unsupported-operation, timers |
| Unable to parse schema | exception | error | java, json-schema, schemas, validation |
| You are using Avro IO with fastavro (default with Beam on… | validation | error | python, apache-beam, avro, fastavro, type-mismatch |
| batch type and element type must have equivalent dtypes | validation | error | apache-beam, pytorch, typehints, dtype |
| error creating local job server | exception | error | go, beam, grpc, job-server |
| Error while parsing the element | console | error | io, tfrecord, parsing, beam, error-handling |
| Failed to generate a unique UUID for schema after 100… | exception | error | python, uuid, schema-registry, assertion |
| No UdfProvider implementation found in | exception | error | java, udf, classpath, service-loader, beam-sql |
| Original transform had an output with tag but upgraded… | exception | error | java, beam, pipeline-construction, transform-upgrade |
| hint -type constraint violated. All %ss should be of type … | exception | error | python, apache-beam, type-hints, dict, runtime-type-check |
| Taking over 5 minutes to flush gcs op batches after error | console | warning | gcs, network, timeout, thread-pool |
| Unsupported Data Catalog entry | exception | error | datacatalog, sql, unsupported-entry |
| BigQueryIO.Write transforms cannot be converted to a… | validation | error | java, bigquery, apache-beam, portability, cross-language |
| Error when parsing input schema file: | exception | error | java, beam, schema, file-io |
| Field is not nullable. | validation | error | java, apache-beam, bigquery, nullability, schema |
| --maxCacheMemoryUsagePercent must be between 0 and 100. | validation | error | java, apache-beam, pipeline-options, validation |
| Unable to parallelize the given query | console | warning | gcp-datastore, query-splitting, parallelism, beam-io |
| Unknown timestamp truncation option | validation | error | java, beam, bigquery, avro, enum |
| Unsupported Firestore value type | validation | error | java, apache-beam, firestore, unsupported-type |
| Cannot get type arguments for | exception | error | java, generics, reflection, udaf, beam-sql |
| Failed to convert Firestore document to Beam Row | exception | error | java, google-cloud-firestore, schema, data-quality |
| FireTimestamp unsupported in | exception | error | java, apache-beam, dofn, timers, unsupported-operation |
| the class must be subclassed properly to get the value | exception | error | cep, type-mismatch, accessor, beam-sql |
| WriteToText requires an input schema with exactly one field. | validation | error | python, apache-beam, yaml, schema, io |
| cannot register component | exception | error | java, apache-beam, cross-language, expansion |
| CDAP plugin class must have Plugin annotation! | exception | error | java, cdap, beam, annotation, unbounded |
| Element argument type | exception | error | java, schema, type-mismatch, conversion |
| EncodingException | exception | error | beam, coder, serialization, java |
| Exception while trying to retrieve schema | exception | error | java, beam, spanner, schema, api-error |