apache/flink
Documented errors, page 7 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Buffer size must be at least 2. | validation | error | input-format, delimited, buffer-size, validation, illegal-argument |
| Failed to deserialize PB object. | exception | error | protobuf, kafka, deserialization, poison-pill |
| Tuple arity ' ' expected but was ' '. | exception | error | type-validation, tuple, arity-mismatch, type-mismatch, reflection |
| Exception in close | exception | error | output-format, close, partition-writer, table-exception, flink |
| Illegal type for protobuf enum, only char/vachar/int/bigint… | exception | error | protobuf, enum, codegen, schema |
| Initial Segment may not be null | exception | error | memory, paged-io, null-pointer, memory-management |
| Encountered exception when reading from avro format file | exception | error | avro, format, data-corruption, io, codec |
| Types that do not implement java.lang.Comparable cannot be… | exception | error | key-type, comparator, generic-type, keyed-stream |
| Error while opening jar file | exception | error | jar, corruption, zip, classpath, download |
| Failed to deserialize Avro record. | exception | error | avro, flink, deserialization, schema-evolution, kafka |
| Failed to open the GeneratorFunction | exception | error | datagen, source-reader, generator-function, lifecycle, test |
| Given class: is not a FunctionalInterface. It does not have… | exception | error | type-extraction, functional-interface, lambda, sam |
| Illegal JSON object data... | exception | error | flink, json, row, schema-mismatch, data-quality |
| Invalid port configuration. Port must be between 0and… | validation | error | configuration, ports, validation, flink-core |
| Queryable state name already set | exception | error | state-descriptor, queryable-state, deprecated, duplicate-call |
| The delta iteration has no initial solution set. | validation | error | iteration, delta-iteration, plan-validation, collection-executor, flink-core |
| Wrapped InputStream: cannot search backwards. | exception | error | io, input-stream, seek, filesystem |
| divisor must be != 0 | exception | error | memory, validation, arithmetic, flink-core-api |
| Invalid S3 URI: missing or empty bucket name in URI | exception | error | s3, uri-parsing, configuration, validation |
| NativeS3FileSystem does not support renaming directories | exception | error | s3, rename, directory, object-store-semantics, unsupported-operation |
| The iteration has no input (initial partial solution). | validation | error | iteration, bulk-iteration, plan-validation, collection-executor, flink-core |
| The value ' ' cannot be represented as an integer number. | exception | error | configuration, duration, parsing, fractional |
| There are no legal characters in the file name | validation | error | flink-core, filesystem, validation, file-lock, sanitization |
| Unsupported serializer type | validation | error | serialization, configuration, parsing, validation |
| Illegal Json Data... | exception | error | flink, json, nested-projection, row, data-quality |
| Logarithm of zero is undefined. | exception | error | math, logarithm, validation, sizing |
| Outer join of type ' ' not supported. | exception | error | |
| The elements in the collection are not all subclasses of | validation | error | datagen, type-system, validation, type-mismatch |
| The given value is not a power of two. | exception | error | math, logarithm, power-of-two, configuration, sizing |
| The task heap memory should be positive. | validation | error | configuration, memory, resource-spec, validation |
| Tuple type expected. | exception | error | type-validation, tuple, type-mismatch, reflection |
| Unable to write to output stream. | exception | error | io, stream, process-output, printstream |
| Failed to retrieve job list. | exception | error | parquet, encoding, unsupported-feature |
| InputSplit must implement Writable interface. | validation | error | hadoop, mapreduce, validation, writable, input-split |
| Orphaned minus sign. | exception | error | parser, byte, malformed-number, csv, flink-core |
| Serializer type not specified for | validation | error | serialization, configuration, parsing, missing-field |
| SQL time type expected. | exception | error | type-validation, sql-time, type-mismatch, reflection, temporal |
| Could not create TypeInformation for type | exception | error | datastream-v2, type-extraction, generics |
| Could not find schema with id | exception | error | avro, confluent, schema-registry, network, kafka, flink |
| Custom partitioners can only be used with keys that have… | exception | error | flink-core, keys, custom-partitioner, partitioning, validation |
| Error parsing arguments | exception | error | cli, arguments, parsing, validation |
| Unknown "type" value | exception | error | canal, cdc, unknown-type, option, runtime |
| Could not write Record. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| Failed to deserialize an element from the source. If you… | exception | error | datagen, serialization, deserialization, custom-type, index-lookup |
| other memory segment has been freed. | exception | error | memory, lifecycle, flink-core, use-after-free |
| S3 connection pool exhausted during bulk copy. The… | exception | error | s3, bulk-copy, connection-pool, configuration, throughput |
| TaskNumber: , numTasks | exception | error | flink, file-output, parallelism, validation, testing |
| The field | exception | error | csv, input-format, validation, api-misuse |
| Error reconstructing URI | exception | error | serialization, deserialization, uri, state, corruption |
| File already exists | exception | error | s3, create, overwrite-mode, idempotency |
| file is not an instance of DistributedFileStatus | exception | error | hdfs, type-mismatch, block-location, api-misuse |
| Hadoop JobConf must not be null when input split is… | exception | error | hadoop-compatibility, input-split, null-check, internal-api |
| SQL time type ' ' expected but was ' '. | exception | error | type-validation, sql-time, type-mismatch, reflection, temporal |
| The delta iteration has no initial workset. | validation | error | iteration, delta-iteration, plan-validation, collection-executor, flink-core |
| Unknown data format. Magic number does not match | exception | error | avro, confluent, schema-registry, wire-format, kafka, flink |
| Cannot have more than | exception | error | stream-context-environment, job-limit, application-mode |
| Cannot instantiate file system for URI | exception | error | hdfs, wrapper-exception, configuration, initialization |
| Collection must not be empty | exception | error | datastream-v2, type-extraction, validation |
| Field types must not be null. | exception | error | flink, csv, input-format, null-check, schema |
| LocalFileSystem cannot recover recoverable for other file… | exception | error | local-filesystem, type-mismatch, sink, recovery |
| The collection contains a null element | validation | error | datagen, validation, null-check, constructor |
| TypeInformation cannot be filled in for the type after it… | exception | error | type-information, type-erasure, datastream-api |
| Avro does not support LOCAL TIMESTAMP type with precision | exception | error | avro, timestamp, precision, flink, schema-conversion |
| Committing file by rename failed | exception | error | azure, abfs, commit, rename, permissions |
| The desired number of splits must be positive or -1 (=… | exception | error | input-format, num-splits, validation, illegal-argument |
| Could not create RecordWriter. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| Generic type ' ' or a subclass of it expected but was ' '. | validation | error | type-extraction, generic-type, type-mismatch, typeinfo |
| Invalid path-style-access | validation | error | s3, configuration, path-style-access, validation |
| Schema provided for ' ' format does not match the table… | exception | error | avro, confluent, schema-mismatch, validation, flink |
| Time unit not recognized | exception | error | parquet, timestamp, time-unit, flink-sql |
| Unable to find the class | exception | critical | avro, state-restore, classloader, class-not-found, flink |
| Cannot access jar file | exception | error | packaged-program, jar, security, catch-all, validation |
| Corrupt data: Unexpected magic number | exception | error | oss, serialization, corrupt-state, magic-number |
| Failed to delegate to ProtoSchemaConverter | exception | error | parquet, protobuf, classpath, reflection, dependency |
| No JAR found on classpath. Please provide a JAR explicitly. | exception | error | |
| Offset is not monotonically ascending. offsets | validation | error | parquet, nested-types, offsets, corruption, reader |
| Could not cancel job | exception | critical | parquet, io, data-corruption, fixed-len-byte-array |
| expanding would create entry outside of | exception | critical | flink-core, compression, security, zip-slip, path-traversal, tar |
| Illegal attempt to write to closed output stream | exception | error | gcs, output-stream, lifecycle, io |
| Invalid character. | exception | error | parser, byte, invalid-character, csv, flink-core |
| Specifying keys via field positions is only valid for tuple… | exception | error | flink-core, keys, expression-keys, tuple, type-system |
| Value overflow/underflow | exception | error | parsing, csv, short, overflow, flink-core |
| Cannot retrieve platform classloader on Java 9+ | exception | critical | classloading, jvm, reflection, startup |
| Could not split string. Illegal quoting at position | validation | error | configuration, structured-parsing, quoting |
| {directory} | exception | warning | flink-core, filesystem, cleanup, race-condition, concurrency |
| Failed to delete | exception | error | s3, delete, permissions, aws-sdk |
| Job was submitted in detached mode. Results of job… | exception | error | execution, detached-mode, runtime |
| Missing data in tmp file | exception | error | filesystem, local-fs, recoverable-writer, recovery, data-loss |
| Some field is missing in the Json data. | exception | error | flink, json, missing-field, nested-projection, options |
| Map item is not a key-value pair (missing ':'?) | validation | error | configuration, map-parsing, legacy |
| No tasks finished successfully. | exception | error | concurrency, executor, invoke-any, failover |
| Operator producing the next version of the partial solution… | exception | error | bulk-iteration, validation, missing-step-function, invalid-program, dataset-api, flink-core |
| Source fetch execution was interrupted | exception | warning | fetcher, interruption, shutdown, flink-source |
| The file path is null. | exception | error | flink, file-output, null-check, lifecycle, testing |
| Unable to find value class. | exception | critical | hadoop, mapreduce, serialization, classloader, value-class |
| Unknown I/O error while extracting contained jar files. | exception | error | packaged-program, jar, io, extraction, temp-files |
| A predicate on a FLOAT column requires a floating literal… | exception | error | flink, orc, predicate-pushdown, type-mismatch, double |
| Cannot register null type class. | validation | error | serialization, pojo, null-check, configuration |
| Could not deserialize Hadoop Configuration, the serialized… | exception | error | |
| Invalid option . Must be a positive integer. | validation | error | config-validation, async-sink, options, flink |