apache/flink
Documented errors, page 4 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Record to serialize to byte array must not be null. | exception | error | serialization, null-handling, validation |
| Target field was added twice to input | validation | error | flink-core, semantic-annotations, forwarded-fields, two-input, dataset-api |
| Failed to read metadata for blob | exception | error | gcs, checksum, metadata, consistency, write |
| malformed input: partial character at end | exception | error | memory, paged-io, utf-8, data-corruption |
| Method currentWatermark isn't supported in… | exception | error | filesystem-connector, partition-commit, configuration, internal-api |
| Output path ' ' could not be initialized. Canceling task... | exception | error | flink, file-output, local-fs, write-mode, overwrite |
| Unable to instantiate the Hadoop InputSplit | exception | critical | hadoop, mapreduce, serialization, classloader, input-split |
| Corrupt Canal JSON message | exception | error | canal, cdc, corrupt-message, kafka, runtime |
| Truncation of file failed because of access/linking… | exception | error | hdfs, dependency-conflict, classloading, truncate |
| A TypeInfoFactory for type | validation | error | serialization, type-information, duplicate, configuration |
| Class is not a TypeInfoFactory. | validation | error | serialization, type-information, typeinfo-factory, validation |
| The class is not a subclass of | exception | critical | checkpointing, restore, upgrade, type-hierarchy, serialization |
| The given class is no subclass of | validation | error | hadoop, type-info, validation, writable, type-extraction |
| Unable to deserialize byte array. | exception | error | json, binary, base64, deserialization, schema |
| Cannot parse ApplicationID from | validation | error | application-id, parsing, hex, validation |
| ComparatorFactory has not been initialized from… | exception | error | lifecycle, comparator, initialization, misuse |
| Could not write bytes since the buffer is full. | exception | error | flink, serialization, record, buffer-full, capacity |
| Duplicated serializer for the same class. | validation | error | serialization, configuration, duplicate, parsing |
| Interrupted while waiting for the previous batch to be… | exception | warning | avro, format, interruption, cancellation, concurrency |
| Local output sorting does not support type | exception | error | flink-core, data-sink, collection-execution, sorting, type-system |
| Bad syntax for classpath | validation | error | cli, classpath, user-input, configuration |
| Bulk Part Writers do not support "pause and resume"… | exception | error | file-sink, bulk-writer, checkpoint, internal-api |
| Failed to put object for key | exception | error | s3, upload, iam, permissions, configuration, flink |
| Unsupported input message | exception | error | filesystem-connector, compaction, internal-api, class-loading |
| Could not skip bytes. | exception | error | flink, serialization, record, eof, bounds-check |
| File path was not specified in input format or… | exception | error | input-format, file-path, configuration, lifecycle, illegal-argument |
| Invalid binary comparison. | exception | error | flink, orc, predicate-pushdown, expression, filters |
| TypeInfoFactory returned invalid TypeInformation 'null' | exception | error | type-extraction, typeinfo-factory, custom-type, null-return |
| Buffer size must be greater than length of delimiter. | validation | error | input-format, delimited, buffer-size, delimiter, validation, illegal-argument |
| bytes must be >= 0 | exception | error | memory, configuration, validation, flink-core-api |
| Unknown Error. TypeInformation is null. | exception | error | type-extraction, internal-error, null-typeinfo, validation |
| Corrupt data: Unexpected magic number %08X | exception | error | file-sink, serialization, corruption, checkpoint |
| The field is already contained in the hierarchy of the… | validation | error | pojo, field-shadowing, class-hierarchy, type-extraction |
| The SplitChange type of | exception | error | split-change, file-source-reader, unsupported-operation, flink |
| Unable to instantiate the hadoop input format | exception | critical | hadoop, mapreduce, serialization, classloader, input-format |
| Unknown resolve order | validation | error | classloader, configuration, startup |
| Failed to submit ExecutionPlan. | exception | error | job-submission, rest-client, network, error-handling |
| The iteration has no next partial solution defined (is not… | validation | error | iteration, bulk-iteration, plan-validation, closewith, flink-core |
| Triggering a detached savepoint for the job | exception | critical | parquet, nested, dictionary, data-corruption |
| Unsupported version | exception | critical | s3, serialization, versioning, state-compat, checkpoint |
| Could not create RecordReader. | exception | error | hadoop, mapreduce, record-reader, interrupted, task-open |
| Failed to deserialize bitmap from bytes. | exception | error | bitmap, roaringbitmap, deserialization, data-corruption, flink-core |
| The 'protobuf' format is not supported for the 'filesystem'… | validation | error | protobuf, filesystem-connector, ddl, validation |
| Unrecognized type: . This method is deprecated and might… | exception | error | configuration, deserialization, corruption, legacy-api, flink-core |
| Writer has already been opened as | exception | error | file-sink, output-stream-writer, internal-api |
| Failed to rename to | exception | error | s3, rename, permissions, aws-sdk |
| Field at index must be of type byte[], but was | validation | error | serialization, row, type-mismatch, kafka |
| The iteration has no solution set delta defined (is not… | validation | error | iteration, delta-iteration, plan-validation, closewith, flink-core |
| Row too short | exception | error | csv, input-format, data-quality, parsing |
| The ExecutorService is shut down already. No Callables can… | exception | error | concurrency, executor, shutdown, lifecycle |
| The given class is no array. | exception | error | type-information, primitive-array, validation, type-extractor |
| Unable to instantiate the hadoop output format | exception | critical | hadoop, mapreduce, serialization, classloader, output-format |
| Unable to load the provided Hadoop codec | exception | error | hadoop, compression, codec, filesystem, configuration |
| Error opening the Input Split | exception | error | flink, file-input, ioexception-wrapper, filesystem, compression |
| Found jar. | exception | critical | python, packaged-program-utils, filesystem, duplicate-jars, flink-home |
| malformed input around byte | exception | error | memory, paged-io, utf-8, data-corruption |
| Unable to serialize VARIANT value. | exception | error | json, variant, serialization, version-mismatch |
| Address cannot be resolved | validation | error | network, dns, flink-core |
| Could not instantiate… | exception | error | avro, dependency, classpath, serialization |
| The filter factor cannot be smaller than zero. | validation | error | flink-core, compiler-hints, optimizer, dataset-api, validation |
| Unrecognized version | exception | critical | serialization, checkpoint, savepoint, version-mismatch, state, io |
| Hostname starts with a | exception | warning | hdfs, hostname, block-location, malformed-data |
| JSON format doesn't support non-string as key type of map… | exception | error | json, map, schema, deserialization, startup |
| negative duration is not supported | exception | error | configuration, duration, parsing, validation |
| Parameterized Tuple type expected. | exception | error | type-validation, tuple, raw-type, generics, reflection |
| Exception in writeRecord | exception | error | output-format, write-record, serialization, table-exception, flink |
| File not found | exception | error | s3, file-not-found, path-handling, object-store-semantics |
| offset1= , offset2= , len= , bufferSize= , address1= … | exception | error | memory, bounds-check, flink-core, sorting |
| The broadcast variable with name | exception | error | broadcast-variable, runtime-context, type-mismatch, user-error |
| The given host:port (' ') doesn't contain a valid host | validation | error | network, configuration, url-parsing, flink-core |
| The record length exceeded the maximum record length | exception | error | input-format, delimited, record-length, delimiter, ioexception, data-quality |
| Unsupported Avro type | exception | error | avro, flink, fixed-type, type-mapping, schema |
| Value for config option | validation | error | configuration, enum, validation, flink-core |
| Csv does not support TIME type with precision | exception | error | csv, time, precision, unsupported-type, ddl |
| Number of input splits has to be at least 1. | validation | error | input-format, parallelism, configuration, runtime |
| The given host:port (' ') doesn't contain a valid port | validation | error | network, configuration, url-parsing, flink-core |
| The size of produced records must be positive. | validation | error | compiler-hints, validation, argument-check, flink-core |
| The unary operation has no input. | validation | error | unary-operator, plan-validation, collection-executor, flink-core |
| There is no enough data left in the DataInputView. | exception | error | memory, paged-io, data-corruption, eof |
| Could not create a valid URI from the given file path name | exception | error | input-format, file-path, uri, path-parsing, runtime-exception |
| Reached the end of the collection. This could be caused by… | exception | error | serialization, from-elements, data-generator, flink |
| can not recover from the pendingFileRecoverable | exception | error | file-sink, recovery, state-compatibility, internal-api |
| Could not commit file from | exception | error | flink, hadoop, filesystem, rename, commit, io |
| fail-on-missing-field and ignore-parse-errors shouldn't… | validation | error | flink, json, ddl, options, validation |
| Failed to acquire out of permits to send value in . | exception | warning | async-sink, rate-limiting, semaphore, timeout, backpressure |
| The types of the interface | exception | error | type-extraction, interface, raw-type, generics, reflection |
| Type at position is not a basic or value type. | exception | error | tuple, value-type, basic-type, type-system, factory-method, flink-core |
| cache file already exists! | exception | error | distributed-cache, plan, duplicate, registration |
| Could not parse URL from | exception | error | rest-client, leader-election, url-parsing, configuration |
| Failed to serialize row. | exception | error | avro, flink, serialization, nullability, rowdata |
| Invalid element type for a primitive array. | exception | error | type-system, array, type-info, illegal-argument |
| Task has been cancelled. | exception | warning | concurrency, executor, future, cancellation |
| Numeric value ( ) out of range of Java byte. | exception | error | flink, json, tinyint, overflow, schema |
| The discovery script executed for over | exception | error | gpu, timeout, process, external-resources |
| The given type is not a parameterized type. | exception | error | type-extraction, generics, raw-type, type-argument |
| Could not find record canonical constructor | exception | error | serialization, records, reflection, classloader |
| Reducer may not be null. | validation | error | hadoop-compatibility, mapred, null-check, constructor |
| The binary operation | validation | error | binary-operator, join, plan-validation, collection-executor, flink-core |
| Unexpected Redistribution Mode | validation | error | |
| Could not create a restore serializer for enum | exception | critical | serialization, state-restore, enum, schema-evolution |