apache/flink

Documented errors, page 9 of 11. Back to apache/flink

Code / MessageTypeSeverityTags
EnumTypeInfo can only be used for subclasses of…
exception error type-info, enum, validation
Join Hint must not be null.
exception error
The given program class does not have a main(String[])…
exception error packaged-program, main-method, jar, entry-point
Field ' ' could not be accessed.
exception error type-system, pojo, reflection, invalid-types-exception
Number of line samples must not be negative.
validation error input-format, delimited, sampling, validation, illegal-argument
Could not skip .
exception error
JAR file does not exist
exception error jar, classpath, file-not-found, deployment
Nested field expression
exception error pojo, nested-field, atomic-type, type-system, flink-core
The given file system URI
exception error hdfs, configuration, fs-defaultfs, uri
The minimum split size cannot be negative.
exception error input-format, split-size, validation, illegal-argument
Unsupported hive version for orc shim
validation error
Field indices must not be smaller than zero.
exception error flink, csv, input-format, validation, field-index
fqdn is null
validation error network, hostname, null-check, configuration
Truncation is not available in hadoop version < 2.7 , You…
exception error hdfs, hadoop-version, truncate, unsupported-operation
Unsupported byte value
exception error flink, row-kind, deserialization, unsupported-operation, changelog
Unsupported type ' ' in node
validation error
Bulk copy failed
exception error s3, bulk-copy, wrapper-exception, diagnostics
Could not register schema in registry
exception error avro, confluent, schema-registry, schema-evolution, auth, flink
Sink with pre-write topology is not supported for…
exception error
Bulk copy interrupted
exception warning s3, bulk-copy, interruption, cancellation
An ordering must not be created with a NONE order.
exception error ordering, validation, flink-core
Mkdirs failed to create
exception error flink-core, compression, filesystem, permissions, tar
Please use AvroParquetReaders.forSpecificRecord
validation error parquet, avro, api-misuse, flink
The is not a directory.
validation error filesystem, validation, configuration
Access to the main method was denied
exception error packaged-program, invocation, module-system, access-denied
Current version of AvroParquetRecordFormat is not…
validation error parquet, avro, splitting, file-source
No exception thrown although the job execution was not…
exception error
Sink with pre-commit topology is not supported for…
exception error
Stream closed.
exception error filesystem, reference-counting, resource-lifecycle, use-after-close
At least one file path must be specified.
exception error input-format, file-path, validation, illegal-argument
Invalid 'format' property in node
validation error
Key type must not be null.
exception error flink-core, keys, type-information, null-check, key-selector
is an unknown value of RestartStrategyType.
validation error configuration, restart-strategy, enum
argument is an empty- or whitespace-only string
exception error memory, configuration, parsing, validation, flink-core-api
Could not close resource.
exception error flink-core, lifecycle, async, shutdown, resource-management
Cannot retrieve Right value on a Left
exception error types, either, flink-core, api-misuse
Could not read page in col
exception error
Error serializing Record header
exception error
Neither a ' ', nor a ' ' entry was found in the jar file.
exception error packaged-program, jar, manifest, main-class, entry-point
The type is not Comparable.
exception error value-type, comparator, comparable, key-type
Enum type expected.
validation error type-extraction, enum, typeinfo, udf
multiplier must be >= 0
exception error memory, validation, arithmetic, flink-core-api
The class must be public.
exception error packaged-program, main-method, access-modifiers
A stream against this file was already created.
exception error parquet, output-stream, single-use, flink
Create dir: failed!
exception error flink-core, compression, zip, filesystem, permissions
Only S3 to local copies are currently supported
exception error s3, bulk-copy, unsupported-operation, api-misuse
Option . is required for serialization
validation error avro, confluent, schema-registry, validation, flink, config
Protocol Buffers editions syntax is not supported
validation error parquet, protobuf, editions, compatibility
The discovery script
exception error gpu, external-resources, permissions, configuration
An object must not allow additional properties in node
validation error
Multiple JAR archives with entry classes found on…
exception error
offset: , length: , size
exception error serialization, memory-segment, bounds-check, validation
The configuration is unmodifiable; its contents cannot be…
exception warning configuration, immutability, unsupported-operation
The record must not be null.
exception error serialization, null-check, string-array
Writable type ' ' expected but was ' '.
validation error hadoop, writable, type-mismatch, typeinfo
could not read page in col
exception error
Directory does not exist or an I/O error occurred
exception error filesystem, local-fs, delete, permissions, race-condition
Failed to get user jar file from blob
exception error
Invalid 'contentEncoding' property in node
validation error
A predicate on a TIMESTAMP column requires a…
validation error
could not read dictionary in col
exception error
Invalid format of Row field expression
exception error row, field-reference, gettypeat, type-system, flink-core
Key extractor must not be null.
exception error flink-core, keys, key-selector, null-check
The Hadoop file system's authority
exception error hdfs, dns, network, configuration
A predicate on a DATE column requires a java.sql.Date…
validation error
Avro does not support TIMESTAMP type with precision
exception error avro, timestamp-ltz, precision, flink, schema-conversion
Column
validation error protobuf, schema-validation, ddl, naming
does not exist
validation error parquet, schema-mismatch, projection, case-sensitivity
Invalid bounds.
exception error serialization, bounds-check, validation, deserialization
Stream is already closed
exception error s3, stream, commit, lifecycle, io
Expecting a primitive variant but got
exception error variant, type-mismatch, flink-core, semi-structured
Unknown type with descriptor
validation error parquet, protobuf, unsupported-type, schema
Avro format doesn't support non-string as key type of map…
exception error avro, map-key, flink, schema-conversion, type-mapping
Cannot convert Protobuf message with extension field(s)
validation error parquet, protobuf, extensions, proto2
POJO type ' ' expected but was ' '.
validation error type-extraction, pojo, type-mismatch, typeinfo
The program's entry point class
exception critical packaged-program, class-loading, static-initializer, initialization
Avro Union with NULL type is only supported. Unsupported…
validation error avro, flink, variant, union, schema
Bucket name in is invalid
validation error gcs, uri, validation, configuration
Can not create a Path from an empty string
validation error path, validation, configuration, filesystem
Collection must not contain null elements
exception error datastream-v2, type-extraction, null-safety
Invalid encoding ' ' in node
validation error
Missing JobID. Specify a JobID to cancel a job.
validation critical parquet, boolean, io, data-corruption
Unsupported vector
validation error
Error untarring file
exception error flink-core, compression, tar, corrupt-archive, process
Invalid type for 'items' property in node
validation error
${message}
validation error config-validation, boolean, properties, flink
The thread was interrupted while waiting for a fetcher task.
exception warning fetcher, interruption, shutdown, flink-source
Cyclic references are not supported
validation error
Do not support flink data type:
exception error protobuf, codegen, serialization, type-mapping
The field ( ) is invalid.
validation error csv, input-format, validation, api-misuse
Failed to list contents of
exception error flink-core, filesystem, permissions, cleanup, io
The tuple arity must be in [0, 25].
validation error
Type at position is null.
exception error tuple, null-check, type-system, factory-method, flink-core
Expression key may not be null.
exception error flink-core, keys, expression-keys, null-check, validation
Invalid 'properties' property for object type in node
validation error
Missing value for the key
exception error map, optional, configuration, table
Unsupported value ' ' for . Supported values are [SQL…
validation error flink, json, options, timestamp, validation
An I/O error occurred while creating temporary file to…
exception error packaged-program, io, temp-files, filesystem, permissions
Could not decode the dictionary for
exception error
Could not find reference
validation error