apache/beam
Documented errors, page 38 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| bad window kind | exception | error | go, beam, windowing, coder |
| Cannot access timerFamily in non-window observing context. | exception | error | java, beam, apache-beam, timers, dofn |
| could not read request body | http | error | |
| Expecting exactly one field, found | validation | error | kafka, schema-transform, raw-format, schema-validation |
| failed to flush chunks for | exception | error | go, filesystem, io, beam-artifacts |
| illegal hex digit | validation | error | firestore, field-name, escaping, hex, java |
| Input to Flatten must be an iterable. Got a value of type | validation | error | python, apache-beam, flatten, iterable |
| Javadoc not generated. Check logs for errors | console | error | gradle, javadoc, build, documentation |
| namespace and name are required to be non-empty, got | panic | error | go, panic, beam, metrics, validation |
| One of topics and topicPartitions must be configurated. | validation | error | beam-sql, kafka, missing-config |
| pipeline should either be a | validation | error | python, type-error, apache-beam, interactive |
| poll_interval_sec must be >= 15, got | validation | error | python, apache-beam, bigquery, config, validation |
| Pubsub message data field of length | validation | error | java, pubsub, payload-size, quota |
| returnLength cannot be 0 or pattern cannot be empty. | validation | error | java, apache-beam, sql, udf, string-functions, argument-validation |
| StepConfig.InitialSplits must be >= 1. Got | panic | error | go, apache-beam, config-validation, panic |
| The provided allow list does not enable expanding a… | exception | error | allowlist, security, configuration |
| Transform is not registered with a supported type. Please… | exception | error | python, mltransform, registry |
| Transform ' ' expects a PCollection as input. Got a… | exception | error | python, apache-beam, type-check, pbegin, pardo |
| Unable to drop active catalog | validation | error | sql, beam-sql, ddl, catalog |
| bad KV | exception | error | go, apache-beam, dataflow, kv-coder |
| bad type: , want | exception | error | go, protobuf, type-mismatch, beam |
| can't get current working directory | exception | error | go, working-directory, os, filesystem |
| Encountered an unsupported mode | validation | error | bigquery, schema, mode, python |
| Error executing async task for element | exception | error | java, async, future, do-fn |
| Finish Bundle should only output WindowedValue type but got | exception | error | python, apache-beam, finish-bundle, windowed-value, runtime-error |
| Id ' ' is already taken. | validation | error | pipeline, context, duplicate-id |
| invalid pcollection | validation | error | go, apache-beam, reshuffle, invalid-pcollection |
| Invalid PCollection | panic | error | go, apache-beam, pcollection, panic, invalid-state |
| mismatched number of named outputs: received | panic | error | go, apache-beam, cross-language, expansion-service |
| No such table | validation | error | beam-sql, metastore, entity-not-found |
| Rate Limit Exceeded, Could not process this batch. | exception | error | python, apache-beam, ml-inference, rate-limit, throttling |
| Re-used coder id | exception | error | |
| Received data after inbound data receiver is done for… | exception | error | java, beam-fn, race-condition, endpoint-closed |
| 'returns' accepts only a single positional argument. In… | validation | error | python, type-hints, apache-beam, decorator |
| StartBundleContext unsupported in | exception | error | apache-beam, java, unsupported-operation, bundle-lifecycle |
| Table must be specified to read with partitions. | validation | error | jdbc, java, validation, partitioning |
| The maximum allowed number of GCS custom audit entries… | validation | error | gcp, gcs, limit, validation, java |
| The private key is unencrypted but private key key… | exception | error | snowflake, private-key, authentication, configuration |
| Tried to merge a non-existent window: | validation | error | java, testing, windows |
| unable to convert LogicalType | exception | error | go, beam, schema, logical-type |
| Unexpected schema argument | validation | error | bigquery, python, apache-beam, schema |
| Unknown CombineFn | validation | error | yaml, config, beam-yaml |
| Unrecognized state type | exception | error | go, apache-beam, state-api, pipeline-translation |
| Unsupported schema specified for Pubsub source in CREATE… | validation | error | java, apache-beam, pubsub, sql, schema |
| Unsupported type for value of display data | validation | error | apache-beam, python, display-data, serialization |
| A pubsub message must not have more than 100 attributes. | validation | error | pubsub, attributes, size-limit, python, apache-beam |
| apache_beam.io.gcp.datastore.v1new.datastoreio.Entity… | validation | error | python, type-mismatch, beam-io, datastore |
| Cannot call refreshSchema after the object has been stopped! | exception | error | java, google-bigquery, lifecycle, illegal-state |
| CoderException(exn) | exception | error | java, beam, decoding, exception-wrapping |
| compressor not initialized | exception | error | python, apache-beam, io, invalid-state |
| Could not find a partition term for | exception | error | java, iceberg, beam, partitioning, configuration |
| Could not find in | exception | error | protobuf, build, missing-dependency, code-generation |
| DynamicMessage is not supported by the ProtoCoder, use the… | exception | error | java, protobuf, coder |
| Expected a callable object instead of: %r | validation | error | python, apache-beam, callable, typeerror |
| expected one output from DataSource, got | error_code | error | go, apache-beam, pipeline-translation |
| file_name_suffix must be a string or ValueProvider;got %r… | validation | error | beam, sink, type-error |
| illegal hex escape sequence | validation | error | java, apache-beam, firestore, field-path, escaping |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, function-arity, panic |
| invalid manifest object | exception | error | gcs, url, beam, go |
| Invalid value " " for "fields". Fields must be a dict. | validation | error | apache-beam, yaml, validation, fields |
| specifies an invalid destination ' '. Please make sure the… | exception | error | yaml, validation, path, code-generation |
| One of JDBC Driver class name or JDBC type must be… | validation | error | jdbc, java, validation, driver |
| Passing a deferred series to round() is not supported… | exception | error | python, apache-beam, dataframe, round, type-mismatch |
| Received null value for non-nullable field | validation | error | java, yaml, schema, null |
| Request failed after exhausting retries. Max retries | exception | error | java, retry, network, remote-inference |
| : table must be of type string; got ValueProvider instead | validation | error | python, apache-beam, bigquery, conflicting-arguments |
| %T isn't a supported encoder function type | panic | error | go, beam, reflection, type-mismatch |
| Transient exception occurred during backlog estimation for… | console | warning | kinesis, backlog, transient-error, autoscaling |
| type(row_index) | exception | error | apache-beam, dataframe, not-implemented, callable-key |
| Unable to rename resource | exception | error | hadoop, hdfs, rename, beam |
| Unknown or inapplicable phase for pre_optimize | validation | error | python, apache-beam, dataflow, cli-argument, pipeline-options |
| Unknown precision: " + this | exception | error | java, apache-beam, avro, timestamp, internal-state |
| Unsupported connector ''. Supported connectors are: | validation | error | java, apache-beam, debezium, config, enum |
| 'agent' must be an Agent instance or a callable. | validation | error | |
| Cannot create object with unspecified or no compression | validation | error | python, apache-beam, io, invalid-enum-value |
| Class ' ' does not implement PipelineRunner. Supported… | validation | error | java, apache-beam, runner, classpath, pipeline-options |
| Could not parse RFC 3339 string | validation | error | python, value-error, timestamp, rfc3339, precision |
| Creating tables is not supported with DataCatalog table… | exception | error | apache-beam, datacatalog, sql, java |
| Database host cannot be empty | validation | error | python, configuration, cloudsql, apache-beam |
| DoFn yields batches from both process and process_batch… | validation | error | python, apache-beam, type-hints, typeerror |
| DoFn yields element from both process and process_batch… | validation | error | python, apache-beam, type-hints, typeerror |
| element_size_fn must be callable | validation | error | python, apache-beam, type-error, constructor, batching |
| empty request body | http | error | http, validation, empty-body |
| Encoded value for the offset consumer config key | validation | error | kafka, deserialization, null-value, offset-consumer-config |
| Error while converting table schema | exception | error | bigquery, schema, json, java |
| failed to parse artifact file payload | exception | error | protobuf, artifact-staging, unmarshal, version-skew |
| For GenericRecord, please call readAvroGenericRecords | exception | error | java, avro, api-misuse, beam |
| grpc.Hook: registered twice | panic | error | go, grpc, panic, initialization |
| If JDBC type is not specified, then Driver Class Name and… | validation | error | jdbc, java, validation, driver |
| Invalid GCS bucket provided! | validation | error | gcs, configuration, google-cloud |
| Metadata instance can not be null | validation | error | spanner, config-validation, null, java |
| Missing required configuration parameters | validation | error | dataflow, configuration, gcp, cli-options |
| Model updates are currently not supported for… | exception | error | python, apache-beam, ml-inference, unsupported-operation |
| No IO transform feeds | exception | error | python, apache-beam, bundle-splitting, graph-wiring |
| not a float type | validation | error | go, apache-beam, coder, type-mismatch, reflect |
| Null RecordReader object returned by | exception | error | hadoop, recordreader, null-pointer, inputformat |
| panic(formatParDoError(dofn, len(ret), 0)) | panic | error | go, beam, pardo, arity |
| Parameter has no schema and the input is not a primitive… | exception | error | apache-beam, java, schema, dofn |
| passert.Hash( ) = ( , ), want ( , ) | exception | error | go, beam, testing, passert, hash |
| RECORD/STRUCT are not primitive types | validation | error | java, apache-beam, bigquery, avro, schema |