apache/flink
Documented errors, page 2 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Unrecognized type. This method is deprecated and might not… | exception | error | configuration, serialization, legacy-api, type-mismatch, flink-core |
| JobStatus does not have a corresponding ApplicationState. | validation | error | application-state, job-status, terminal, state-machine |
| Multiple compatible client factories found for | exception | error | deployment, service-loader, configuration, classpath |
| The class ' ' is not instantiable | exception | error | reflection, instantiation, validation |
| Type of TypeVariable | exception | error | type-extraction, type-erasure, generics, type-variable |
| The generic type parameters of | exception | error | type-extraction, lambda, generics, type-erasure, common |
| totalValueCount == 0 | exception | error | parquet, corruption, metadata, io, flink |
| Unrecognized Kryo registration serializer definition type | exception | error | kryo, snapshot, internal-invariant, flink-core |
| Could not find class | exception | critical | checkpointing, restore, upgrade, migration, classloader, serialization |
| Couldn't retrieve standalone cluster | exception | error | deployment, standalone, rest, network, cluster-connection |
| {} | exception | error | row, comparator, key-position, arity-mismatch, dataset-api |
| Schema evolution not supported. | exception | error | parquet, schema-evolution, type-mismatch, flink |
| Unable to deserialize message | exception | error | serialization, deserialization, io, schema-mismatch |
| Cannot find any jar files for plugin in directory | exception | error | plugins, configuration, flink-core, filesystem |
| Could not stop with a savepoint job | exception | error | parquet, nested, type-mismatch, unsupported-feature |
| Invalid port range | validation | error | configuration, ports, validation, flink-core |
| PostVersionedIOReadableWritable cannot read from a… | exception | error | serialization, versioned-io, api-misuse, unsupported-operation |
| Premeture EOF from inputStream | exception | error | io, stream, custom-stream, eof |
| Compaction reader not support DataStructure converter. | exception | error | table-sink, compaction-reader, data-structure-converter, unsupported-operation, flink |
| Corrupt data: Unexpected magic number. | exception | error | s3, serialization, state-restore, corruption |
| Interrupted while uploading object for key | exception | warning | s3, interruption, cancellation, transfer-manager, concurrency, flink |
| Please invoke DeserializationSchema#deserialize | exception | error | flink, json, deserialization, deprecated-api, array |
| Could not configure serializers from | validation | error | serialization, configuration, parsing, error-wrapping |
| Could not initialize comparator | exception | error | type-information, comparator, reflection, java-time |
| Could not serialize comparator into the configuration. | exception | error | serialization, comparator, java-serialization, job-submission |
| TypeInformation ' ' does not supply a mapping of… | exception | error | type-extraction, typeinfo-factory, generics, custom-type |
| Invalid cluster id " ". The expected format is [0-9a-fA-F]… | validation | error | application-mode, configuration, cluster-id, high-availability |
| Error during Java deserialization. | exception | error | serialization, kryo, deserialization, state-migration, flink-core |
| Tuple needs to be parameterized by using generics. | exception | error | type-extraction, tuple, generics, reflection |
| Unknown field name ' ' for mapping to a row position… | exception | error | row, serializer, named-fields, schema-mismatch, field-name |
| Corrupt data, conflicting lengths. Length fields | exception | error | serialization, data-corruption, framing, versioned-io |
| Comparator specifies an invalid length for the normalized… | exception | error | comparator, normalized-key, custom-comparator, contract-violation |
| The gpu discovery script does not exist in path | exception | error | gpu, external-resources, configuration, file-not-found |
| Basic type expected. | exception | error | type-validation, basic-type, type-mismatch, reflection |
| Corrupt Ogg JSON message | exception | error | flink, ogg, json, deserialization, corrupt-data |
| Wrong classifier chain; Circular chain of classifiers… | validation | error | async-sink, classifier, cycle-detection, programming-error |
| CharSequence is too long. | exception | error | serialization, stringvalue, overflow, flink-core |
| Input mismatch | exception | error | type-validation, input-mismatch, type-extraction, reflection |
| Unknown ColumnIO | exception | error | parquet, corruption, array, internal-invariant, flink |
| Cannot instantiate tuple. | exception | error | tuple, instantiation, reflection, typeutils |
| No termination condition is set (neither fix number of… | exception | error | bulk-iteration, validation, termination, invalid-program, dataset-api, flink-core |
| The transformation does not support async state, or you are… | exception | error | async-state, keyed-state, transformation, streaming |
| Cannot use the key partitioner for composite keys (more… | exception | error | group-reduce, custom-partitioner, composite-key, dataset-api, flink-core |
| Corrupt data, magic number mismatch. Expected %8x, found %8x | exception | critical | serialization, checkpoint, savepoint, data-corruption, state, io |
| Could not instantiate type | exception | error | reflection, instantiation, constructor-exception |
| Directory not empty and recursive = false | exception | error | s3, delete, directory, object-store-semantics |
| Illegal escape from target directory | exception | error | security, zip-slip, filesystem, archive |
| Input type of coGroup must be one of composite types or… | exception | error | cogroup, type-system, comparator, invalid-program, dataset-api, flink-core |
| Schema provided for ' ' format must be a nullable record… | exception | error | debezium, avro, schema-validation, format-options |
| Seek to many rows. | exception | error | parquet, seek, metadata-mismatch, flink |
| The "before" field of | exception | critical | debezium, postgres, replica-identity, cdc, update |
| Generic types have been disabled in the ExecutionConfig and… | exception | error | type-info, generic-type, kryo, execution-config |
| Internal error occurred. | exception | error | type-extraction, lambda, unary-operator, internal-error |
| Wildcard expressions are not allowed here. | exception | error | type-extraction, tuple, field-expression, wildcard |
| Cannot initialize fields. | exception | error | pojo, serialization, reflection, field-access, java-modules |
| Result for Job is UNKNOWN | exception | warning | job-result, rest-client, unknown-state, ha |
| Row arity of record ( ) does not match this serializer's… | exception | error | row, serializer, arity-mismatch, serialization, schema |
| Could not create CSV generator. | exception | error | csv, jackson, bulk-writer, filesystem, io |
| Could not create writer state serializer. | exception | error | file-sink, filesystem, serializer, configuration, connectivity |
| Segment size must be a power of 2! | validation | error | memory, validation, flink-core, configuration |
| Exception when trying to initialize plugin system. | exception | critical | plugins, startup, flink-core, configuration |
| Failed to serialize schema registry. | exception | error | avro, flink, serialization, schema-mismatch |
| Job is in state SUSPENDED | exception | warning | job-status, rest-client, suspended, recovery |
| The Flink config file | validation | error | configuration, missing-file, startup, migration, flink-core |
| Corrupt Maxwell JSON message | exception | error | flink, maxwell, json, deserialization, corrupt-data |
| The implementation of AbstractDeserializationSchema is… | exception | error | serialization, generics, type-erasure, type-information |
| The Kryo Output still contains data from a previous… | exception | error | serialization, kryo, buffer-overflow, flink-core |
| Unsupported type | validation | error | configuration, type-conversion, configoption |
| You must have forgotten to call open() on your input format. | exception | error | input-format, binary, lifecycle, checkpoint, open |
| Can't deploy a standalone cluster. | exception | error | deployment, standalone, unsupported-operation |
| Could not un-export our RMI registry | exception | warning | jmx, rmi, shutdown, flink-core |
| The bytes are serialized with version | exception | critical | hybrid-source, state-serialization, version-mismatch, checkpoint-restore |
| The class has no main(String[]) method. | exception | error | packaged-program, main-method, invocation |
| The configuration directory was not specified. Please… | exception | critical | cli, configuration, environment, startup |
| The request entry sent to the buffer was of size | validation | error | async-sink, record-size, buffer, validation |
| Byte array does not provide enough space to store requested… | exception | error | flink, serialization, record, index-out-of-bounds, argument-validation |
| Could not find a free permitted port on the machine. | exception | error | network, ports, concurrency, environment, flink-core |
| Failed to abort multipart upload for key | exception | warning | s3, multipart-upload, cleanup, idempotency, iam, flink |
| Failed to close current reader | exception | error | hybrid-source, source-reader, resource-cleanup, source-transition |
| Given configuration directory is null, cannot load… | validation | error | configuration, null-argument, startup, flink-core |
| Unsupported protobuf simple type: | exception | error | protobuf, codegen, schema-mismatch |
| Could not copy element. | exception | error | serialization, type-serializer, copy, null-safety |
| Byte array to deserialize from must not be null. | exception | error | serialization, null-handling, validation |
| Cannot extract the type argument with index | exception | error | type-extraction, generics, type-argument, lambda |
| Failed to create the parent directory | exception | error | local-filesystem, filesystem-io, permissions, sink |
| Serializer does not support named field positions. | exception | error | row, serializer, named-fields, schema, position-based |
| Translator cannot translate the given pipeline . | exception | critical | parquet, encoding, dictionary, data-corruption |
| Unsupported page type | exception | error | parquet, version-conflict, page, classpath, flink |
| Could not access the MODEL$ field of avro record | exception | error | avro, flink, reflection, classloader, jvm-modules |
| Only simple types are supported in the second level nesting… | exception | error | csv, nesting, type-information, unsupported-type |
| Unable to instantiate Hadoop InputSplit | exception | critical | hadoop, mapred, serialization, classloader, input-split |
| Unknown encryption type | validation | error | configuration, encryption, sse, kms, s3, flink |
| Unsupported type information | exception | error | csv, schema, type-information, unsupported-type |
| Could not create the type information for | exception | error | state-descriptor, type-information, type-erasure, generics, type-extractor |
| Incomplete-tail object | exception | critical | s3, recovery, state-corruption, checkpoint, invariant |
| Unable to recover the job as the expected | exception | critical | azure, abfs, recovery, file-sink, io |
| Configuration cannot evaluate value | validation | error | configuration, type-mismatch, legacy-api, flink-core |
| Could not write bytes. Buffer overflow. | exception | error | serialization, memory, flink-core, buffer-overflow |
| Line could not be parsed | exception | error | csv, input-format, data-quality, parsing |
| Unsupported type of source, you could use… | exception | error | datastream-v2, source, api-migration, flip-27 |