apache/beam
Documented errors, page 46 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| element type mismatch, previous additions were of type | validation | error | go, testing, teststream, type-mismatch |
| EmbeddableItem must have at least one embedding (dense or… | validation | error | python, qdrant, embeddings, data-validation |
| Error matching file spec | exception | error | java, apache-beam, filesystem, io, retry |
| Error trying to access nonexistent attribute | exception | error | apache-beam, bigquery, attribute-error, typo |
| Expecting messageName to be non-null. | validation | error | kafka, schema-transform, proto, missing-required-argument |
| experiment worker_region and option workerZone are mutually… | validation | error | dataflow, gcp, configuration, experiments |
| Failed to load ONNX file | exception | error | onnx, tensorrt, apache-beam, ml-inference, model-loading |
| Google Cloud Vision not supported for this execution… | exception | error | |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, function-signature |
| Incompatible func type: got func | panic | error | go, reflection, arity-mismatch, panic |
| Need to set either the topic or the subscription for a… | validation | error | java, pubsub, configuration, beam |
| Standard logical type | exception | error | java, apache-beam, reflection, constructor |
| structural DoFn passed by value, ensure that the… | exception | error | go, apache-beam, dofn, method-set |
| {timer.time_domain} | exception | error | apache-beam, timers, unsupported-feature, pardo |
| artifact not found | exception | error | beam, lookup, artifact |
| cannot encode a null PredictionResult | exception | error | java, beam, coder, null |
| element was type %T, previous additions were of type | validation | error | go, testing, teststream, type-mismatch |
| Failed to create client for | exception | error | gcs, authentication, network, beam |
| Failed to push prebuilt sdk container | exception | error | apache-beam, docker, registry-push, authentication |
| Found multiple builders under key | exception | error | apache-beam, container-image, ambiguous-lookup, registration-conflict |
| Full trace: \n Output of the failed child process | exception | error | python, subprocess, command-failed |
| hdfs_port is not set | validation | error | hdfs, configuration, python, apache-beam |
| invalid DoFn | exception | error | go, apache-beam, dofn |
| Keys to be deleted from Cloud Datastore must be complete | validation | error | python, datastore, validation, beam-io |
| Not supported by SnowflakeIO. | exception | error | snowflake, unsupported-operation, streaming, api-misuse |
| Only atomic_type and array_type option values are currently… | validation | error | python, schema, options, serialization |
| The file cannot be found. It was specified in the… | exception | error | python, cli, file-not-found, beam |
| timestamp not accessible in this context | exception | error | python, apache-beam, dofn-context, timestamp, attribute-error |
| Unable to find inbound timer receiver for instruction | exception | error | java, beam-fn, timers, receiver-registration |
| unexpected number of parameters in method | validation | error | go, apache-beam, watermark, validation |
| can't apply processing delay of less than a millisecond. Got | panic | error | go, apache-beam, trigger, panic, duration |
| element type is , want | panic | error | go, reflection, type-mismatch |
| exists() operation failed | exception | error | s3, io, aws, existence-check |
| Expected to find a single mapping constructor but found | exception | error | java, reflection, ambiguity, constructor-overload |
| hdfs_user is not set | validation | error | hdfs, configuration, python, apache-beam |
| Incompatible func type: got func | panic | error | go, reflection, arity-mismatch, panic |
| Invalid input specified. It must be a dict. | validation | error | apache-beam, yaml, join, validation |
| invalid status for combine merge | validation | error | go, beam, lifecycle, state-machine, combine |
| location is not a GCS object | exception | error | gcs, url, validation, beam |
| Not yet implemented. | exception | error | kafka, secrets, unsupported-operation |
| PCollection not part of a pipeline. | exception | error | python, apache-beam, ptransform, pipeline-context |
| PCollections of different lengths, got | exception | error | go, beam, testing, passert, floats |
| Tokens ( , ): two nodes have the same token | exception | error | java, cassandra, token-ring, duplicate-token |
| trigger argument to trigger.Repeat() cannot be nil | panic | error | go, beam, trigger, nil-pointer |
| Could not decode bytes as message | exception | error | java, protobuf, deserialization, schema |
| Could not find an expansion service jar for the managed… | validation | error | |
| Expected a subclass of proto.Message, but got a | validation | error | python, protobuf, coders, apache-beam |
| Failed to decode URL parameters: | validation | error | jdbc, clickhouse, url-parsing, encoding |
| lenientFormat(errorMessageTemplate, p1) | validation | error | java, null-check, arguments |
| Missing combine parameter in Combine config. | validation | error | yaml, config, beam-yaml |
| publish_time_field must be a non-empty field name. | validation | error | python, apache-beam, pubsub, validation |
| is for internal use only and does not support case dispatch | exception | error | java, apache-beam, internal-api, unsupported-operation |
| spannerio.Query: specifying timestamp bound for non-batched… | panic | error | go, apache-beam, spanner, unsupported-feature |
| TableFieldsQueryConfig must provide non-empty… | validation | error | python, apache-beam, cloudsql, dataclass, validation |
| ValueProvider.get implemented in derived classes | exception | error | apache-beam, python, abstract-method |
| Cannot create reader as source is not split yet. | exception | error | hadoop, beam, invalid-state, reader |
| cannot make schema encoder for type | exception | error | go, beam, reflection, struct, exported-fields |
| cannot return null keyCoder | exception | error | beam, keyedpcollectiontuple, keycoder, illegal-state |
| Could not upload to GCS path | exception | error | dataflow, gcs, permissions, upload, credentials |
| error connecting to MongoDB | exception | critical | mongodb, connection, network, configuration |
| Expected non-negative n, received | validation | error | apache-beam, combiners, argument-validation |
| invalid logical type, bad id | panic | error | go, apache-beam, schema, logical-type, panic |
| Invalid value " " for "equalities". " " is not a specified… | validation | error | apache-beam, yaml, validation, join |
| lenientFormat(errorMessageTemplate, errorMessageArgs) | validation | error | java, null-check, arguments |
| MapTuple can be used only with callable objects. Received… | validation | error | python, apache-beam, maptuple, callable |
| num_retries parameter cannot exceed 10000. | validation | error | retry, validation, config |
| : file_pattern must be of type string or ValueProvider; got… | validation | error | python, apache-beam, io, source, type-mismatch |
| hint type-constraint violated. The type of element # in the… | validation | error | python, apache-beam, type-hints, nested-types |
| source_file_names and destination_file_names should be… | exception | error | python, apache-beam, hdfs, argument-validation |
| Start Bundle should not output any elements but got | exception | error | python, apache-beam, dofn-lifecycle, runtime-error |
| at least one input column must be specified | validation | error | python, vertex-ai, embeddings, validation |
| Cannot write to SHOW DATABASES | exception | error | |
| Could not infer Beam schema for class | exception | error | java, avro, schema, beam |
| could not unmarshal CoderRef from | exception | error | go, apache-beam, coder, serialization |
| could not unmarshal length prefix coder component | exception | error | go, coder, length-prefix, unmarshaling |
| database_config must be VectorDatabaseWriteConfig, got | validation | error | python, apache-beam, rag, type-error, vector-db |
| f'Unknown window type | validation | error | python, apache-beam, yaml, windowing |
| func must be specified and it must be callable | validation | error | apache-beam, dataframe, type-error, callable-required |
| micros_instant logical type encountered a Java Instant with… | exception | error | java, timestamp, precision, logical-type |
| Not expected to access RestrictionTracker from a regular… | exception | error | java, apache-beam, dofn, testing, unsupported-operation |
| is missing expected tag | validation | error | beam, schema-transform, singlestore, tag-mismatch |
| Source %r is empty. | validation | error | python, apache-beam, empty-source, test-harness |
| The --experiment='jar_packages=' option expects a full path… | validation | error | python, cli, validation, beam |
| union value index not in range [0.. ] | exception | error | java, apache-beam, coder, index-out-of-range, serialization |
| AUTO is applicable only to reading files | exception | error | java, io, compression, unsupported-operation |
| bad iterable/stream: %+v | exception | error | go, beam, iterable, coder-deserialization |
| base map cannot be nil | panic | error | go, reflection, nil-map |
| error deleting object | exception | error | aws, s3, network, storage |
| Expect fields, but actually | validation | error | csv, schema, parsing |
| Expected JSON array for field | validation | error | beam, json, array, deserialization |
| f"When using include, it must be the only parameter | validation | error | yaml, python, apache-beam, provider-config |
| Host cannot be empty in JDBC URL: | validation | error | jdbc, clickhouse, url-parsing, configuration |
| Incompatible func type: got func | panic | error | go, apache-beam, reflectx, panic, function-signature |
| Incompatible func type: got func | panic | error | go, apache-beam, reflectx, panic, function-signature |
| Invalid device value | validation | error | python, apache-beam, machine-learning, huggingface, invalid-device |
| Invalid value " " for "type". It must be a dict or a str. | validation | error | apache-beam, yaml, join, validation |
| LogAppendTimePolicy policy is enabled in reader, but Kafka… | exception | error | |
| panic(formatParDoError(dofn, len(ret), 2)) | panic | error | go, beam, pardo, arity |
| Parameter argv, if specified, must be a list. Received : %r | validation | error | apache-beam, python, type-error |
| Type ' ' not supported. | exception | error | java, arrow, beam-schema, type-conversion |