apache/beam

Documented errors, page 9 of 49. Back to apache/beam

Code / MessageTypeSeverityTags
WriteToKafka(with_headers=True) only supports…
validation error apache-beam, python, kafka, unsupported-serializer, headers
zero length key
panic error go, beam, prism, key, panic
Buffer size exceeds GRPC limit . This is likely due to a…
exception critical apache-beam, python, grpc, payload-size
Could not find class
exception error java, classpath, reflection
could not unmarshal coder from
exception error beam, go, pipeline-deserialization, coder
Does not support converting DECIMAL type value
exception error java, beam, bigquery, avro, decimal
error bulk writing to MongoDB
exception error mongodb, database, write, beam-io
error in getLocal()
exception error go, jar, classpath, network
Failed to determine if the source is splittable
exception error java, io, compression, runtime-exception
failed to discover column
exception error database, metadata, driver, beam-io
instanceId can't be empty
validation error java, apache-beam, google-cloud-spanner, validation
invalid side pcollection: index
validation error apache-beam, go, side-input, pipeline-construction
Making progress out of range
exception error parquet, progress-tracking, apache-beam, internal
not a unsigned integer type
validation error go, apache-beam, coder, type-mismatch, reflect
One of withTable() or withQuery() is required
validation error beam, singlestore, configuration, missing-argument
OnTimer function is defined for the DoFn but no…
validation error go, apache-beam, dofn, timers, validation
Pipeline option pickle_library=dill_unsafe is set, but dill…
exception error python, dependency, pickle, dill, installation
PipelineOptions objects are not serializable and should not…
exception error java, serialization, apache-beam, pipeline-options
retrieving time data
exception error beam, decoding, serialization, truncated-data
Timeout waiting for Python service startup after
exception error java, python, timeout, expansion-service, network
Type interface isn't a supported PCollection type
validation error go, beam, ptransform, type-system
Unrecognized dialect: + dialect.name()
validation error java, spanner, dialect, configuration
Unsupported runner .
validation error sql, unsupported-runner, interactive-beam
Use of withMaxBufferingDuration requires…
console warning java, apache-beam, elasticsearch, configuration
Cancelled mutateRow request after exceeding deadline
exception error bigtable, timeout, metadata, latency
Cannot encode elements of type
exception error java, apache-beam, coders, assignability
Cannot provide a coder for a Beam Row. Please provide a…
exception error java, apache-beam, schema, row
Encountered Bad Record:
exception critical java, apache-beam, error-handling, bad-record, pipeline-failure
First entry is null when initial sequence is set.
exception error apache-beam, combiner, state-corruption, invariant
Found multiple definitions of scalar function
exception error udf, duplicate, beam
Incompatible func type: got func
panic error go, apache-beam, reflection, panic, function-signature
Invalid ARRAY type: + originalSpannerType
validation error java, beam, spanner, schema, type-parsing
Not a KV coder: .
exception error python, apache-beam, coders, kv
not all required stateful watermark estimation methods are…
validation error go, apache-beam, sdf, watermark-estimator, missing-method
number of emits in method
validation error go, apache-beam, dofn, signature-validation, pipeline-construction
Postgres does not support connectionInitSql.
validation error jdbc, postgres, beam, configuration
throttleDelaySecs must be greater than 0
validation error java, beam-io, constructor-validation, throttling
Unable to determine BatchGet resumption point. Most…
exception error firestore, beam, batchget, resume-token
Unable to generate builder factory for clazz
exception error java, reflection, schemas
Unexpected exception fetching database schema.
exception error java, reflection, debezium, classpath, apache-beam
Unexpected number type
panic error go, beam, stats, types
A function must be provided to convert the input type into…
validation error java, bigquery, apache-beam, missing-argument
bigquery write error
exception error bigquery, write, quota, go
Cannot find a matching Calcite SqlTypeName for Beam logical…
exception error beam-sql, calcite, schema, logical-type
Encountered Pubsub message with ordering key but this sink…
console warning java, pubsub, ordering-key, configuration, data-loss
Expected a with components but received
exception error java, beam, proto, oneof, decoding
Failed assert: element
exception error python, apache-beam, assertion, windowing, test
failed to create TypeKey for receiver type %T
exception error go, beam, dofn, type-key
Failed trying to process value for key
exception error java, io, kafka, configuration
Job finished in state
exception error job-state, runner, pipeline-failure
Metric namespace must be non-empty
validation error python, apache-beam, metrics, validation
Pool - unknown case which is likely a bug: state= seqnum=
console error kinesis, enhanced-fan-out, state-machine, checkpoint
prism runner doesn't support the following required features
validation error go, beam, prism-runner, compatibility
schema type must be struct
panic critical go, bigquery, panic, type-mismatch
SolaceIO.Write: Trying to create a batch of
exception error solace, java, batch-size, write, limit-exceeded
The file cannot be found. It was specified in the…
exception error python, apache-beam, staging, file-not-found
tried cross-language for
panic critical go, apache-beam, cross-language, expansion-service
Unable to create a side-input view from input
exception error java, apache-beam, side-input, windowing
Unable to deterministically encode
exception error apache-beam, python, coder, serialization, pickle
unexpected param kind
validation error
An error occurred
exception error jms, null, mapper
Append to stream by client # failed with error, operations…
console warning bigquery, grpc, retry, append
attempted to add namespace to missing windowing strategy id
panic critical go, apache-beam, cross-language, windowing, panic
can't (safely) pickle generator objects
exception error python, apache-beam, dill, pickling, generator
error loading AWS config
panic critical go, aws, s3, config, panic
Error parsing JSON
exception error beam-sql, json, record-parsing
Expected Iterable for array field.
validation error java, apache-beam, firestore, type-mismatch
Failed to create Dataflow client. Pipeline options are…
exception error python, gcs, pipeline-options, artifact-location
Failed to read PipelineOptions from Protocol
exception error java, apache-beam, pipeline-options, jackson, deserialization
illegal codepoint
validation error firestore, field-name, escaping, unicode, java
inferCoder failed: interface type
validation error go, beam, coder-inference, reflection
nil coder at index
panic error go, beam, coder, nil-pointer
PCollection with more than one element accessed as a…
validation error java, apache-beam, singleton-view, illegal-argument
RestrictionSize has unexpected number of return values
panic error go, apache-beam, splittable-dofn, type-mismatch
translated with URN ' ' but payload was not a
exception error pipeline-graph, protobuf, windowing, translation, java
Scalar expression of type partitoned by non-singleton
exception error python, apache-beam, dataframe-api, partitioning
the GroupByKey requires its output coder to be
exception error apache-beam, java, coder, groupbykey, validation
Unable to parse representation
exception error java, json, deserialization, apache-beam
unable to provide to worker
error_code error go, beam, artifacts, worker
vocab_size is not specified. Tried to infer vocab_size from…
exception error python, apache-beam, tft, vocab-size
Calling .triggering() to specify a trigger or calling…
validation error java, apache-beam, windowing, triggers, pipeline-construction
Current record is unavailable because either the reader is…
exception error apache-beam, java, source-reader, synthetic-source, streaming
Dataflow runner currently supports Python versions
exception error python, apache-beam, dataflow, version-compatibility
decodeStream value decode failed on close
error_code error go, apache-beam, decoding, stream
error executing splitVector command
exception error mongodb, go, splitvector, split
error in creating relative path
exception error go, filesystem, path, jar
error validating file path
exception critical go, security, zip-slip, path-traversal
failed to get manifest
exception error go, grpc, beam-artifacts, legacy-api, network
Failed to get table schema for table:
exception error java, clickhouse, beam, schema, metadata
Invalid secret type , currently supported types
validation error java, beam, secrets, configuration, unsupported
SplunkEvent can hold arbitrary instances, which may be…
validation error apache-beam, java, coder, splunk, determinism
stage[ ] no parent ID for side input
panic critical go, beam, prism, side-input, panic
The configuration class
exception error java, beam, reflection, javabeans
Timeout waiting for the service
exception error java, timeout, network, service-startup, connection
Type " " of kind " " not permitted in concrete types. All…
validation error go, apache-beam, type-system, serialization
Unknown spec type ' ' in
exception error python, anomaly-detection, registry, spec
Unknown URN
exception error apache-beam, java-harness, metrics, urn
Unsupported logical type:
exception error bigtable, schema, logical-type, java
window fn ( ) does not have a determanistic coder ( )
validation error python, apache-beam, windowing, coder, determinism
2xx codes should not be exceptions. Got status code
validation error java, google-cloud-healthcare, http, illegal-argument, invariant