apache/flink
Documented errors, page 6 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| The "before" field of | exception | critical | flink, ogg, json, cdc, postgres, replica-identity |
| and are not compatible | exception | error | flink-core, keys, join, type-compatibility, dataset-api |
| Usage of class Tuple as a type is not allowed. Use a… | exception | error | type-extraction, tuple, raw-type, type-erasure |
| An error occurred while invoking the program's main method | exception | error | packaged-program, invocation, linkage-error, bytecode |
| Cannot have more than | exception | error | stream-context-environment, job-limit, streaming, application-mode |
| Cannot register null class or serializer. | validation | error | serialization, kryo, null-check, configuration |
| Fail to serialize at field | exception | error | json, row, field-conversion, serialization, runtime |
| Field expression must be equal to '*' or '_' for atomic… | exception | error | keys, sorting, type-system, flink-core |
| FieldIndex mismatch name= | validation | error | parquet, protobuf, schema-evolution, field-order |
| Only support seek at first. | exception | error | parquet, seek, api-misuse, flink |
| Schema must be set when using Generic Record | validation | error | avro, flink, batch, schema, configuration |
| The Accumulators cannot be fetched through the Job Client… | exception | error | |
| A user-provided generator function threw an exception on… | exception | error | datagen, generator-function, user-code, runtime |
| could not decode the dictionary for | exception | error | parquet, encoding, dictionary, corruption, io, flink |
| Could not load the AvroSerializer class. You may be missing… | exception | error | avro, missing-dependency, serializer, state |
| JAR file does not exist | exception | critical | parquet, nested, rle, levels, data-corruption |
| Line could not be parsed | exception | error | csv, input-format, data-quality, parsing |
| Memory segment does not represent off heap memory | exception | error | memory, unsafe, flink-core, api-misuse |
| Type Information could not be created. | exception | error | type-extraction, unsupported-type, reflection, catch-all |
| Unsupported data type in schema: | exception | error | protobuf, codegen, serialization, schema |
| A flattened field can not be a composite type | exception | error | type-system, composite-type, internal-invariant, field-selector |
| Cancelling the job is not supported by the Job Client when… | exception | error | |
| Could not look up the main(String[]) method from the class | exception | error | packaged-program, reflection, security, main-method |
| Failed to dispose the savepoint | exception | critical | parquet, nested, io, data-corruption |
| Object is not serializable | exception | error | serialization, closure-cleaner, user-function |
| The directory dose not exist. | validation | error | filesystem, validation, configuration |
| Type extraction is not possible on Either type as it does… | exception | error | type-extraction, either, generics, type-info |
| Unknown "op" value " ". The Debezium JSON message is | exception | error | debezium, cdc, unknown-op, option, runtime |
| Not support to parse type | exception | error | json, raw-type, serialization, schema, startup |
| This state is only accessible by functions executed on a… | exception | error | keyed-state, state, valuestate, runtime-context, user-error |
| Unsupported partition commit trigger | exception | error | |
| Unsupported policy | exception | error | |
| Committable to compact has no content. | exception | error | file-sink, compaction, internal, state-restore, defensive |
| Failed to Java-Deserialize an AvroSerializer instance. Was… | exception | critical | avro, state-restore, checkpoint, serialization, flink |
| The number of specified keys is different. | exception | error | flink-core, keys, join, cogroup, dataset-api, type-compatibility |
| The value ' ' cannot be re represented as 64bit number of… | exception | error | memory, parsing, overflow, configuration, flink-core-api |
| Unknown field name ' ' for mapping to a position. | exception | error | flink, row, field-name, illegal-argument, schema-mismatch |
| Value type expected. | exception | error | type-extraction, value-type, typeinfo, udf |
| Comparator does not support null-aware serialized… | exception | error | comparator, null-handling, serialized-comparison, unsupported-operation |
| Failed to deserialize JSON | exception | error | flink, json, deserialization, kafka, data-quality |
| name must not be null | validation | error | distributed-cache, null-check, task, runtime-context |
| Unknown "op_type" value | exception | error | flink, ogg, json, cdc, parse-error |
| Could not copy object by serializing/deserializing it. | exception | error | kryo, serialization, copy, state |
| Currently only block sizes up to Integer.MAX_VALUE are… | exception | error | input-format, binary, block-size, limit, unsupported-operation |
| encoded string too long | exception | error | memory, paged-io, utf-8, size-limit |
| Error reading field as | exception | error | |
| The key is only defined for keyed operator | exception | error | |
| Could not access the fields of the user defined class while… | exception | error | |
| Task id too large. | exception | error | hadoop-compatibility, output-format, parallelism, configuration |
| The partitioner is incompatible with the key type… | exception | error | flink-core, keys, custom-partitioner, type-compatibility, validation |
| Could not parse Avro schema string. | exception | error | avro, flink, schema-parsing, json, configuration |
| The input contains an empty argument | validation | error | cli, configuration, validation, flink-core |
| The output cardinality cannot be smaller than zero. | validation | error | compiler-hints, validation, argument-check, flink-core |
| The program's entry point class | exception | error | packaged-program, class-loading, class-not-found, jar |
| Unable to retrieve Azure storage key from environment. | exception | error | azure, credentials, environment, configuration |
| Unsupported variant type | exception | error | serialization, variant, internal-api |
| Encoded string reached maximum length | exception | critical | serialization, utf-8, string, size-limit, memory |
| FileSystem has been closed for bucket | exception | error | s3, lifecycle, use-after-close, filesystem-cache |
| interrupted while acquiring lock | exception | warning | s3, concurrency, interruption, cancellation, io |
| Please use AvroParquetReaders.forGenericRecord | validation | error | parquet, avro, schema, api-misuse |
| Partition sorting does not support type | validation | error | |
| Resource guard was already closed. | exception | error | concurrency, lifecycle, resource-management, shutdown |
| Cannot convert type to class | exception | error | type-extraction, generics, type-variable, reflection |
| Could not extract type information. | exception | error | type-extraction, create-typeinfo, unsupported-type, typeinfo-factory |
| Invalid version | exception | error | serialization, checkpoint-restore, hybrid-source, version-mismatch, flink |
| Missing JobID. Specify a Job ID to manipulate a checkpoint. | validation | critical | parquet, nested, page-v1, data-corruption |
| Some field is missing in the JSON data. | exception | error | flink, json, missing-field, options, schema |
| The given host:port (' ') is invalid | validation | error | network, url-parsing, ipv6, flink-core |
| The number of partitions must be at least 1. | exception | error | iterator, parallelism, validation, split |
| Unexpected trigger result | exception | error | file-sink, compaction, internal, defensive, unreachable |
| Checksum mismatch writing blob | exception | critical | gcs, checksum, data-corruption, write, consistency |
| Could not build the program from JAR file | exception | critical | parquet, rle, io, data-corruption |
| Hadoop File System abstraction does not support scheme | exception | error | hdfs, classpath, filesystem-scheme, configuration |
| is not supported now. | exception | error | parquet, unsupported-type, flink |
| Method currentProcTime isn't supported in… | exception | error | filesystem-connector, partition-commit, configuration, internal-api |
| org.apache.hadoop.io.Writable type expected. | validation | error | hadoop, writable, type-mismatch, typeinfo |
| Problem with jar file | exception | error | jar, classpath, configuration, deployment |
| TypeInfo annotation does not specify a valid… | validation | error | type-extraction, typeinfo-annotation, typeinfofactory, configuration |
| Avro does not support TIMESTAMP type with precision | exception | error | avro, timestamp, precision, flink, schema-conversion |
| Could not get job jar and dependencies from JAR file | exception | error | parquet, encoding, unsupported-feature |
| Invalid port configuration. Port must be between 0and… | validation | error | configuration, ports, validation, flink-core |
| Memory segment does not represent heap memory | exception | error | memory, off-heap, flink-core, api-misuse |
| The given offset is not contained in the any block. | exception | error | flink, file-input, hdfs, block-location, metadata |
| The positions must be strictly increasing (no permutations… | validation | error | csv, input-format, validation, api-misuse |
| This stub is not part of an iteration step function. | exception | error | rich-function, iteration, runtime-context, misuse |
| Type information for input of type | exception | error | |
| Error creating field union of record data | exception | error | |
| Key types if input KeyedStreams don't match | validation | error | |
| No value present | exception | error | flink, optional, no-such-element, null-handling |
| Cannot fetch from another split - no split remaining | exception | error | file-source-reader, split-exhaustion, io-exception, flink |
| Cannot support file system for | exception | error | hdfs, classpath, dependency-conflict, linkage-error |
| Entropy length must be >= 0 when entropy injection key is… | validation | error | s3, configuration, entropy-injection, validation |
| Invalid assume-role.session-duration | validation | error | s3, configuration, assume-role, validation |
| Serialization failed because the record length would exceed… | exception | critical | serialization, size-limit, memory, array-overflow |
| The output size cannot be smaller than zero. | validation | error | compiler-hints, validation, argument-check, flink-core |
| Unsupported map null key handling mode | exception | error | flink, json, options, map, validation |
| Compaction file not exist | exception | error | filesystem-connector, compaction, filesystem, io |
| Could not find a public truncate method on the Hadoop File… | exception | error | hdfs, hadoop-version, reflection, truncate |
| Could not invoke the main method, arguments are not… | exception | error | packaged-program, invocation, reflection, argument-mismatch |
| Exception encountered during finding the flink-python jar… | exception | critical | python, packaged-program-utils, filesystem, environment, flink-home |