apache/beam
Documented errors, page 32 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Side inputs must have defaults for FlatMapTuple. | validation | error | python, apache-beam, flatmaptuple, side-inputs |
| Table row mutation failed. Table Available/Enabled… | exception | error | hbase, write-failure, mutation, bigtable |
| This container does not exist. Creating containers is not… | exception | error | azure, blobstore, container, file-not-found |
| This runner does not currently support committed metrics… | exception | error | apache-beam, metrics, runner-compatibility |
| Type of field is unknown. | exception | error | java, schemas, type-mapping |
| unable to decode ParDoPayload for | exception | error | go, beam, protobuf, descriptor |
| Unexpected null element type on " + field.getName() | exception | error | java, bigquery, beam-schema, collection |
| Unknown Avro type: " + type.getType() | validation | error | java, apache-beam, bigquery, avro, schema, unsupported-type |
| Unknown mode: " + mode | exception | error | java, apache-beam, internal-state, version-skew |
| Unsupported merging strategy | validation | error | python, apache-beam, windows, windowing-strategy |
| Unsupported watermark_policy: | validation | error | kinesis, watermark, invalid-enum, config |
| bad return type | exception | error | go, apache-beam, serialization, function-signature |
| buildDescriptor: invalid stage - no transforms at all | exception | error | beam, prism, stage, pipeline-graph |
| Cannot get column index from | exception | error | sql, join, column-index, beam |
| Cannot interpret as seconds. | validation | error | python, type-mismatch, timestamp, apache-beam |
| change_function must be 'CHANGES' or 'APPENDS', got | validation | error | python, apache-beam, bigquery, enum, validation |
| Couldn't set the specified Avro data model | exception | error | parquet, avro, reflection, apache-beam |
| Data does not contain the following columns | exception | error | python, apache-beam, schema |
| EOF encountered decoding a ValueKind | exception | error | java, beam, coder, eof, deserialization |
| Expected single output type hint for | validation | error | python, type-hints, apache-beam |
| Expected weight to be > 0 for | validation | error | python, apache-beam, state-cache, cache, validation |
| failed to connect | exception | error | go, grpc, network, beam, status |
| Failed to convert configuration map to YAML. The following… | exception | error | |
| failed to read from | exception | error | gcs, io, storage, permissions |
| Failed to set oneof to proto. oneof | exception | error | protobuf, beam, oneof, exception-wrap |
| File path must be absolute: | exception | error | beam, unix-domain-socket, endpoint, configuration |
| FlattenWith only takes other PCollections and PTransforms… | validation | error | python, apache-beam, flatten, type-mismatch |
| fn.getIncompatibleGlobalWindowErrorMessage() | exception | error | java, windowing, combine |
| format requires valid schema to be passed to schema… | validation | error | python, apache-beam, yaml, pubsub, missing-argument |
| In-file test fixing not yet supported for templated… | exception | error | yaml, testing, templates |
| Input to _GroupByKeyOnly must be a PCollection of windowed… | validation | error | apache-beam, groupbykey, type-check, python |
| "IQR.learn_one expected univariate input, but got | validation | error | python, anomaly-detection, validation, univariate |
| mismatched watermark state type in method | validation | error | go, apache-beam, sdf, watermark-estimator, type-mismatch |
| Namespace cannot be empty. | validation | error | bigquery, python, configuration, empty-string |
| No Runner was specified and the DirectRunner was not found… | exception | error | apache-beam, classpath, runner-configuration |
| Object type must have either properties or… | validation | error | python, apache-beam, json-schema, schema |
| Only strings allowd as map keys when converting to JSON… | exception | error | python, apache-beam, json, type-mismatch |
| OnTimer and ProcessElement functions for DoFn should have… | validation | error | go, apache-beam, dofn, validation, timers |
| Output has tags but expected output tags | validation | error | apache-beam, java, yaml-transform, validation |
| Private key encryption algorithm not supported. This may… | exception | error | snowflake, private-key, openssl, jvm-compatibility |
| " " requires a pipeline to be specified as there are no… | validation | error | python, apache-beam, pipeline |
| source decode failed | error_code | error | beam, go, decoding, coder |
| Standard logical type | exception | error | java, apache-beam, reflection, access-modifier |
| %T isn't a supported decoder function type | panic | error | go, beam, reflection, type-mismatch |
| The file cannot be found. It was specified in the… | exception | error | apache-beam, staging, pip, file |
| The file cannot be found. It was specified in the… | exception | error | python, cli, file-not-found, beam |
| TupleCoder does not have exactly 2 components. | exception | error | python, coders, apache-beam |
| Unable to get result coder | exception | error | apache-beam, coder, output, pipeline-construction |
| unable to partition query | panic | critical | go, apache-beam, spanner, panic, sql, gcp |
| Unexpected field ' ' in top level schema for Pubsub… | exception | error | java, pubsub, beam, schema, illegal-argument |
| Unsupported database adapter type | exception | error | python, apache-beam, cloudsql, enum, sqlalchemy |
| Unsupported vector type: <type.getClass()> | exception | error | java, apache-beam, delta-lake, unsupported-type, columnar |
| Was expecting a RexCall or a boolean RexInputRef, but… | exception | error | java, apache-beam, mongodb, sql, predicate-pushdown |
| append() only accepts DeferredDataFrame instances, received | exception | error | pandas, apache-beam, dataframe, type-mismatch |
| ArrowFlightIO.write(): e.getMessage() | exception | error | arrow, flight, schema, beam |
| Bad coder for output of | validation | error | python, apache-beam, pipeline-validation, coders |
| BigQuery table " + tableReference + " not found. If you… | exception | error | bigquery, resource-not-found, storage-write, gcp |
| Can only append fields on a schema'd input. | validation | error | apache-beam, yaml, schema |
| Can't cast non-numeric types: +input | exception | error | java, apache-beam, cast, type-mismatch |
| CompletionException | exception | error | java, concurrency, futures, interrupt |
| Could not determine a valid schema for parameter class | exception | error | java, schema, beam, schema-registry |
| Could not find the feature service | exception | error | python, apache-beam, feast, resource-not-found |
| couldn't connect to docker | exception | error | go, beam, prism-runner, docker, connection |
| Currently, dynamic clustering and timepartitioning is not… | exception | error | apache-beam, bigquery, storage-write-api, not-implemented, dynamic-destinations |
| Datadog write failed: | exception | error | java, apache-beam, datadog, network |
| Embeddings can only be generated on dict[str, str].Got dict | exception | error | python, type-mismatch, embeddings |
| Empty match for pattern | exception | error | io, file-pattern, empty-match |
| Error creating URI '" + providedUrl + "' from a list of " +… | exception | error | neo4j, apache-beam, uri, url |
| error decoding append bag user state window key | panic | error | go, beam, prism, state, windowing, panic |
| Expected single output PCollection in reshuffle: | panic | error | go, apache-beam, prism-runner, reshuffle |
| Expected sinkGroupId to be provided when EOS is set to true | validation | error | java, apache-beam, kafka, config-validation, exactly-once |
| f'Ambiguous transform at line | validation | error | yaml, beam-yaml, pipeline-definition, ambiguity |
| gcp dependencies not installed. Cannot use | validation | error | dependencies, gcp, beam-yaml |
| GroupIntoBatchesWithShardedKey | panic | error | go, apache-beam, panic, invalid-params |
| Header metadata already has a worker_id. | exception | error | python, apache-beam, grpc, interceptor, metadata |
| Illegal Pubsub object name specified | validation | error | java, pubsub, naming, beam |
| Invalid TestStream event | validation | error | python, apache-beam, teststream, testing |
| Invalid value for yield_elements argument | validation | error | python, dataframe, invalid-argument, enum |
| KafkaUnboundedReader's curRecord is null. | exception | error | java, kafka, deduplication, nosuchelement |
| may only have a single state.Provider parameter and it must… | validation | error | |
| No RabbitMQ channel available | exception | error | rabbitmq, amqp, apache-beam, connection |
| num_splits must be > 1, got | exception | error | python, datastore, argument-validation, beam-io |
| PaneInfo unsupported in | exception | error | apache-beam, java, unsupported-operation, windowing |
| Please specify a BigQuery table to read from. | validation | error | python, apache-beam, bigquery, io |
| Process environment variable | validation | error | java, apache-beam, environment-variables, config-parsing |
| Pubsub object name cannot start with goog | validation | error | java, pubsub, naming, beam |
| Reserved field name <field.name()> in user schema. | exception | error | java, apache-beam, bigquery, avro, schema |
| not found. Please build the server with \n cd ; ./gradlew | exception | error | python, java, build, missing-artifact, apache-beam |
| Setting the number of Storage API streams is only… | console | warning | java, apache-beam, bigquery, bounded-input |
| source_info must a three tuple where firstitem of the tuple… | validation | error | apache-beam, python, testing |
| The Apache Beam SDK for Python is only supported on Python… | exception | critical | python, python2, import, version-check |
| the comparator is not supported | exception | error | java, nfa, cep, comparator, sql |
| The feature store yaml path | validation | error | python, apache-beam, feast, file-not-found |
| Unable to setup job. | exception | error | hadoop, hadoopformatio, job-setup, hdfs |
| Unknown request type " + msg.request.oneofKind | exception | error | artifacts, protobuf, version-skew, runner |
| Write disposition has to be one of the following… | validation | error | apache-beam, python, snowflake, enum |
| AvroCoder for GenericRecord requires a schema | exception | error | java, apache-beam, avro, coder |
| Bigquery dependencies are not installed. | exception | error | python, apache-beam, bigquery, missing-dependency, load-testing |
| Class has final fields and no registered creator. Cannot… | exception | error | java, schema, reflection, immutability |
| Config class must be not null! | exception | error | java, cdap, beam, null-argument, reflection |