apache/beam
Documented errors, page 35 of 49. Back to apache/beam
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| num_workers ( ) cannot be negative | validation | error | dataflow, config-validation, pipeline-options, workers |
| Object not found | exception | error | gcs, not-found, metadata |
| : Timeout while initializing partition ' '. Kafka client… | exception | error | java, kafka, network, timeout, connectivity |
| smallBatchTag and largeBatchTag must not be null | validation | error | java, iceberg, beam, argument-validation |
| Table schema must be of the type bigquery.TableSchema | validation | error | python, apache-beam, bigquery, schema, type-error |
| temp_dataset has to be either str or DatasetReference | validation | error | bigquery, type-mismatch, beam, python |
| The category ' ' is not supported. | exception | error | java, schema, hcatalog, complex-types |
| There are no more Rows. | exception | error | java, apache-beam, arrow, iterator |
| Unrecognized value for stable unique names: | exception | error | java, beam, configuration, enum, cli |
| Value too large (negative). | exception | error | python, serialization, integer-overflow, apache-beam |
| " " argument must be specified, Valid values are | validation | error | java, cli, missing-argument, validation |
| Attempting to call and() on a CoGbkResult apparently not… | exception | error | beam, cogbkresult, illegal-argument, misuse |
| axis must be one of ('index', 0, 'columns', 1). got | validation | error | python, apache-beam, dataframe, axis-argument |
| cannot encode a null byte[] | exception | error | java, apache-beam, coder, null, serialization |
| Could not generate external transform wrappers due to error | exception | error | python, subprocess, codegen, build |
| Could not obtain a Coder for the accumulator | exception | error | java, beam, combine, coder |
| Duplicate table: from provider | exception | error | beam-sql, metastore, name-collision |
| Either a read_artifact_location or write_artifact_location… | validation | error | python, apache-beam, configuration |
| error computing pipeline facts | exception | error | go, beam-prism, pipeline-graph, preprocessing |
| Expected JSON object for field | validation | error | beam, json, nested-row, deserialization |
| external key not found | exception | error | beam, go, serialization, type-registry, graphx |
| Failed to refresh shards. | console | warning | kinesis, aws, iam, throttling, background-refresh |
| Invalid JDBC URL format. Expected 'jdbc:clickhouse:' or… | validation | error | jdbc, clickhouse, url-parsing, configuration |
| invalid status for combine | validation | error | go, beam, lifecycle, state-machine |
| "IQR.score_one expected univariate input, but got | validation | error | python, anomaly-detection, validation, univariate |
| Item missing both text content and sparse embedding… | exception | error | python, apache-beam, milvus, rag, embeddings |
| Main output tag %r must be different from side output tags… | validation | error | python, apache-beam, pardo, output-tags |
| MatchContinuously interval must be positive. | validation | error | python, apache-beam, io, validation |
| Materialization in out-of-process and remote runners is not… | exception | error | python, apache-beam, runner-limitation |
| specifies a destination for an invalid SDK: ' '. The… | exception | error | yaml, validation, code-generation, invalid-key |
| nrows not yet supported | validation | error | python, apache-beam, dataframe, io |
| Row schema cannot be null for type: " + fieldType | validation | error | mongodb, apache-beam, schema, null |
| Serialized pubsub message exceeds the publish request limit… | validation | error | pubsub, payload-too-large, serialization, python, apache-beam |
| Shared Server Process crashed | exception | error | python, multiprocessing, process-crash, initialization |
| SolaceIO.Read: Cannot infer a coder for the TypeDescriptor… | exception | error | solace, beam, coder, schema |
| 'timeout' must be a non-negative number | validation | error | python, apache-beam, queue, timeout |
| Unable to parse statement | exception | error | sql, parsing, jdbc |
| A VPC network must be provided to use a private endpoint. | validation | error | apache-beam, vertex-ai, gcp, vpc, validation |
| Attempting to drop a table using unexpected Calcite Schema… | validation | error | sql, ddl, internal-error |
| bad symbol | exception | error | go, deserialization, worker, apache-beam |
| bad windowed value | exception | error | go, beam, windowing, coder-serialization |
| Bounded Source is not BigQueryStorageStreamSource, unable… | exception | error | bigquery, storage-api, type-mismatch, java |
| Encountered exceptions in finalize_write | exception | error | python, apache-beam, io, rename, concurrency |
| Expected the path to be not null | exception | error | java, yaml, config, missing-key |
| expected to end with . can't generate valid code | panic | error | go, codegen, panic, imports |
| failed to marshal window coder | exception | error | beam, go, coder, windowing |
| illegal trailing backslash | validation | error | java, apache-beam, firestore, field-path, escaping |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, function-arity, panic |
| Incompatible func type: got func | panic | error | go, apache-beam, reflection, function-arity, panic |
| invalid WindowInto payload for | exception | error | go, apache-beam, windowing, protobuf |
| JsonRowWriter is not readable | exception | error | bigquery, io, file, python |
| key_coder | exception | error | python, apache-beam, coders, kv |
| KeyedModelHandler cannot map records to multiple models if… | validation | error | python, apache-beam, ml-inference, incompatible-options |
| Must provide context when not using SimpleInvoker | exception | error | python, apache-beam, invoker |
| Nested type in " " not permitted in concrete types. | validation | error | go, apache-beam, type-system |
| Pubsub subscription is not in projects/ | validation | error | java, pubsub, url-format, beam |
| Schema is not instanceof CatalogManagerSchema or… | validation | error | sql, pipeline-options, internal-error |
| Setting a number of Storage API streams is only supported… | console | warning | java, apache-beam, bigquery, configuration |
| Standard logical type | exception | error | java, apache-beam, reflection, logical-type |
| start_offset must be smaller than stop_offset. Received | validation | error | offset, value-out-of-range, constructor |
| syntax error: unclosed | validation | error | go, apache-beam, gcs, glob, regex |
| Unable to infer a coder for destination type (inferred from… | exception | error | java, apache-beam, coder, serialization, file-io |
| Unknown transform type %r at | exception | error | yaml, beam-yaml, pipeline-definition, unknown-type |
| Unsupported debugMode '" + value + "'. Supported values are… | validation | error | java, snowflake, enum, parsing |
| unsupported type for clone | panic | error | go, reflection, unsupported-type |
| : requires at least 1 return value. | validation | error | beam, go, combinefn, signature-validation |
| WatermarkEstimator unsupported in | exception | error | java, apache-beam, unsupported-operation, bundle-finalizer |
| Window type-constraint violated. Valid object instance must… | exception | error | python, apache-beam, type-hints, windowing |
| with_exception_handling with TensorFlow Transform-based… | exception | error | python, apache-beam, tft, exception-handling |
| batch size must be greater than 0 | validation | error | go, apache-beam, mongodb, config-validation |
| Can't initialize symbol resolver. | panic | error | go, apache-beam, cli, panic, symbols |
| Clusters in the global region are not supported. | validation | error | gcp, dataproc, deprecation, python |
| Could not determine port for pubsub root url | exception | error | java, pubsub, url, configuration, port |
| Could not find enum descriptor | exception | error | python, apache-beam, protobuf, deserialization |
| Could not locate yaml docs source directory | console | warning | python, docs, build, missing-directory |
| decoding time | exception | error | beam, decoding, time-format, serialization |
| DoFns that observe windows must be invoked with single… | validation | error | beam, go, windowing, dofn |
| Either where_clause_fields or where_clause_value_fn must be… | exception | error | python, cloudsql, batching, configuration |
| error must be the final return parameter | validation | error | |
| Expected watchTopicPartitionDuration to be available when… | validation | error | kafka, dynamic-read, config, missing-field |
| Getter has wrong prefix | exception | error | java, javabeans, beam-schema, naming-convention |
| Max batch size exceeded.%nBatch size needs to be equal or… | validation | error | java, google-cloud-vision, batch-size, apache-beam |
| Most ( ) and least ( ) significant bits value shouldn't be… | exception | error | java, schema, logical-type, null |
| Param validation failed on part number | validation | error | aws, s3, multipart-upload, validation |
| Provided length is bigger than max length | validation | error | java, snowflake, schema, validation |
| scheme must be 's3' | validation | error | go, apache-beam, s3, filesystem, url-scheme |
| shift(axis= ) is only supported with freq defined, and… | exception | error | pandas, apache-beam, dataframe, order-sensitive |
| target_batch_duration_secs_including_fixed_cost | validation | error | python, apache-beam, batchelements, config-validation |
| targetBatchDurationSecs | validation | error | java, builder-validation, batching |
| Timeout waiting for asynchronous computation completion. | exception | error | timeout, async, interactive-beam |
| Timestamp precision must be between 0 and | exception | error | python, apache-beam, timestamp, precision, range-check |
| Triggers never set or called for batch default windowing. | exception | error | python, apache-beam, trigger, batch, windowing |
| UNABLE TO CONVERT FIELD | exception | error | java, schema-conversion, kafka-connect, apache-beam |
| Unable to decode constant members from payload for… | exception | error | java, beam, coder, deserialization, ioexception |
| Unable to find translator for basic operator | exception | error | missing-translator, operator-registration, beam, euphoria |
| unable to start sdk worker | panic | error | go, grpc, panic, worker-pool, beam |
| Unknown Beam read property | validation | error | java, beam-sql, delta-lake, table-properties |
| unknown coder used for ordered list state after re-write id | exception | error | go, beam, state, ordered-list, coder |
| unknown window type | panic | error | go, beam, windowing, unsupported |
| Unsupported metadata column | validation | error | java, delta-lake, cdc, argument-validation, metadata-columns |