apache/flink
Documented errors, page 5 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Could not instantiate record | exception | error | serialization, records, reflection, kryo |
| Failed to deserialize CSV row | exception | error | csv, deserialization, dirty-data, kafka, parsing |
| The merged accumulator must be AverageAccumulator. | validation | error | accumulator, average, merge, type-mismatch |
| Error while getting the file registered under | exception | error | distributed-cache, interruption, concurrency, taskmanager |
| Missing JobID. Specify a Job ID to trigger a savepoint. | validation | critical | parquet, nested, dictionary, data-corruption |
| Output directory ' ' could not be created. Canceling task... | exception | error | flink, file-output, local-fs, directory, write-mode |
| Recoverable writers on AzureBlob are only supported for ABFS | exception | error | azure, abfs, wasb, scheme, file-sink |
| The given file system URI | exception | error | hdfs, configuration, uri, fs-defaultfs |
| The value ' ' cannot be re represented as 64bit number… | exception | error | memory, parsing, overflow, configuration, flink-core-api |
| Cannot downcast long value | exception | error | math, overflow, casting, sizing, validation |
| Could not extract lambda method out of function | exception | error | type-extraction, lambda, reflection, classloader, security |
| Failed to create Avro encoder. | exception | error | avro, flink, json-encoding, schema-validation |
| Target field was added twice. | exception | error | semantic-properties, forwarded-field, annotation, flink-core |
| Unsupported partition commit predicate | exception | error | |
| Value for configuration key= | exception | error | configuration, properties, parsing, validation |
| The accumulator object | exception | error | accumulator, classloader, isolation, fat-jar |
| Unable to create recoverable outputstream as length of file | exception | critical | azure, abfs, recovery, truncation, file-sink |
| Unsupported type ' ' for field ' '. | exception | error | csv, schema, logical-type, unsupported-type |
| An IO error occurred while accessing the staging FileSystem. | exception | error | output-format, staging-directory, io-error, filesystem, flink |
| Cannot use custom partitioner for a non-grouped GroupReduce… | exception | error | group-reduce, custom-partitioner, keyed-operation, dataset-api, flink-core |
| Could not fetch next KeyValue pair. | exception | error | hadoop, mapreduce, record-reader, interrupted, iteration |
| Format cannot define a quote character and disabled quote… | validation | error | csv, validation, format-options, ddl |
| Missing key | exception | error | map, optional, configuration, table |
| Missing type for included field | exception | error | flink, csv, input-format, schema, validation |
| Type for included field | exception | error | flink, csv, input-format, null-check, schema |
| Cannot clean commit: Staging file does not exist. | exception | error | hdfs, file-sink, commit, staging-file, recovery |
| Input type of GroupReduce must be one of composite types or… | exception | error | |
| JSON format doesn't support failOnMissingField and… | exception | error | flink, json, deserialization, config, validation |
| Table options do not contain an option key | validation | error | table-factory, format-option, validation, ddl, flink |
| The DeltaIteration meta operator cannot have broadcast… | exception | error | delta-iteration, broadcast-variable, unsupported-operation, dataset-api, flink-core |
| The runtime context has not been initialized. | exception | error | rich-function, runtime-context, lifecycle, user-error |
| Unable to deserialize default value. | exception | error | state-descriptor, deserialization, checkpoint-restore, type-serializer, version-skew |
| Unrecoverable exception while trying to recover | exception | critical | azure, abfs, commit, savepoint-recovery, data-loss |
| Unsupported timestamp format | exception | error | flink, json, options, timestamp, validation |
| could not read page in col | exception | error | parquet, corruption, io, page, flink |
| Failed to initialize GoogleHadoopFileSystem | exception | error | gcs, google-cloud, credentials, filesystem, initialization |
| Field expression must be equal to '*' or '_' for… | exception | error | keys, type-system, keyby, flink-core |
| Number of key fields and comparators differ. | exception | error | comparator, join, co-group, key-selector, illegal-argument |
| S3 File System cannot recover recoverable for other file… | validation | error | s3, api-misuse, recoverable-writer, type-check |
| The class ' ' is not a subclass of ' ' as is required. | exception | error | reflection, classloader, api-mismatch |
| URL is invalid. This should not happen. | exception | error | packaged-program, url, filesystem, defensive |
| {checkpointInfo.getFailureCause()} | exception | error | checkpoint, rest-client, async-operation |
| Could not load deserializer from the configuration. | exception | error | serialization, deserialization, version-mismatch, classloader |
| Discovery script exit with non-zero return code | exception | error | gpu, process-exit-code, external-resources, diagnostics |
| Failed to trigger a checkpoint for the job | exception | critical | parquet, nested, page-v2, data-corruption |
| Given class: is not a FunctionalInterface. It has more than… | exception | error | type-extraction, functional-interface, lambda, sam |
| Invalid format of tuple field expression | exception | error | type-extraction, tuple, field-expression, invalid-format |
| Please override the method. | exception | critical | async-sink, missing-override, api-contract, programming-error |
| this memory segment has been freed. | exception | error | memory, lifecycle, flink-core, use-after-free |
| Could not add a comparator for the logicalkey field index | exception | error | type-system, composite-type, comparator, key-selector, illegal-argument |
| Name and aggregator must not be null | validation | error | aggregator, iteration, null-check, registration |
| no codec for codecByte | validation | error | avro, format, codec, validation, versioning |
| Recoverable writer not available | exception | error | s3, recoverable-writer, unsupported-operation, configuration |
| The iteration has no workset defined (is not closed). | validation | error | iteration, delta-iteration, plan-validation, closewith, flink-core |
| Unknown Error. Type is null. | exception | error | type-extraction, internal-error, null-type, validation |
| A predicate on a LONG column requires an integer literal… | exception | error | flink, orc, predicate-pushdown, type-mismatch, bigint |
| A savepoint cannot be taken through the Job Client when in… | exception | error | |
| Buffer too small: capacity | exception | error | kryo, serialization, buffer, stream-corruption |
| Cannot clean commit: File has trailing junk data. | exception | error | filesystem, local-fs, recoverable-writer, commit, race-condition |
| Return type of KeySelector is not a valid key type | exception | error | flink-core, keys, key-selector, type-information, validation |
| The configuration directory | exception | critical | cli, configuration, environment, startup |
| The type cannot be used as a key. | exception | error | type-information, comparator, key-type, keyby |
| There is leading or trailing whitespace in the numeric… | exception | error | parser, bigdecimal, whitespace, csv, flink-core |
| Unsupported to derive Schema for type | exception | error | avro, timestamp-ltz, flink, schema-conversion, legacy |
| Unsupported value ' ' for option . Supported values are . | validation | error | flink, json, options, map, sink, validation |
| JSON format doesn't support to serialize map data with null… | exception | error | json, map, null-key, option, serialization |
| Properties file does not exist | exception | error | configuration, file-io, classpath, flink-core |
| RecoverableWriter has been closed | validation | error | s3, lifecycle, writer, state, io |
| The given file system URI | exception | error | hdfs, configuration, invalid-uri, fs-defaultfs |
| Cannot parse JobID from | validation | error | job-id, parsing, hex, validation |
| exception in queue future completion | exception | error | blocking-queue, future, internal, flink-source |
| Native S3 File System cannot recover recoverable for other… | validation | error | s3, type-mismatch, filesystem, recovery, config |
| Type at position is not a basic type. | exception | error | tuple, basic-type, type-system, factory-method, flink-core |
| Unable to find key class. | exception | critical | hadoop, mapreduce, serialization, classloader, key-class |
| Array type expected. | exception | error | type-validation, primitive-array, type-mismatch, reflection, array |
| Failed to trigger a savepoint for the job | exception | error | parquet, nested, type-mismatch, vector |
| {savepointInfo.getFailureCause()} | exception | error | savepoint, rest-client, async-operation |
| A predicate on a STRING column requires a floating literal… | exception | error | flink, orc, predicate-pushdown, type-mismatch, string, misleading-message |
| Cannot set a UDF as combinable if it does not implement the… | exception | error | group-reduce, combiner, interface-check, dataset-api, flink-core |
| Could not stop with a detached savepoint job | exception | error | parquet, nested, dictionary, type-mismatch |
| Serializing the source elements failed | exception | error | serialization, type-information, from-elements, flink |
| The return type of function | exception | error | type-information, type-erasure, datastream-api |
| Unsupported encoding | exception | error | parquet, encoding, legacy-format, flink |
| {asynchronousOperationInfo.getFailureCause()} | exception | error | savepoint, rest-client, async-operation |
| Incompatible versions of the Hadoop Compatibility classes… | exception | critical | hadoop, writable, version-mismatch, classpath |
| Invalid tuple field reference | exception | error | row, field-reference, type-system, flink-core |
| The jar file path is invalid. | validation | error | jar, packaged-program, path-validation, uri |
| The value ' ' cannot be represented as Duration (numeric… | exception | error | configuration, duration, overflow, parsing |
| Type information extraction for tuples (except Tuple0)… | validation | error | type-extraction, tuple, generic-types, typeinfo |
| Concrete subclass of Tuple expected. | exception | error | type-validation, tuple, raw-type, type-mismatch, reflection |
| Exactly one of LocalDate and LocalTime is null. | exception | error | serialization, datetime, corrupt-data |
| Failed to find related Parquet column descriptor with type | validation | error | parquet, schema, nested-types, column-not-found, flink |
| The Nothing type cannot have a serializer. | exception | error | type-information, nothing-type, sentinel, serializer |
| Corrupt artifact fetching state. | exception | warning | artifact-fetch, internal, unreachable, assertion |
| {e.getMessage()} | exception | error | datagen, serialization, index-lookup, constructor |
| Illegal count (must be non-negative) | exception | error | avro, serialization, internal, flink |
| Record deserialization with leading normalized keys not… | exception | error | row, comparator, unsupported-operation, normalized-key, dataset-api |
| An aggregator is already registered under the given name. | exception | error | aggregator, iteration, duplicate, registration |
| Not allowed configuration change(s) were detected:\n | exception | error | stream-context-environment, configuration, validation, mutated-config, security |
| SerializerFactory has not been initialized from… | exception | error | lifecycle, type-serializer, initialization, misuse |