ErrLookup › apache/flink
apache/flink
Apache Flink · Java · 10,337 source files
Analyzed at 30b5f50125 on 2026-09-05. 1031 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Unsupported operation | exception | error | |
| No parser available for type | exception | error | csv, input-format, type-system, runtime |
| The window uses a merging assigner, but the window state is… | exception | critical | flink, datastream-v2, windowing, session-windows, state-backend, operator-init |
| This object is a dummy TypeSerializer. | exception | critical | serialization, state, checkpoint, savepoint, classpath, class-not-found, unsupported-operation |
| Cannot deserialize and unwrap accumulators properly. | exception | warning | accumulators, embedded, application-mode, serialization, classloader |
| Do not support external resource in current environment | exception | error | external-resource, gpu, runtime-context, unsupported-operation, local-execution |
| not a valid mode | exception | error | |
| Window is not in in-flight window set. | exception | error | flink, datastream-v2, windowing, session-windows, merging-window-set, state-consistency |
| Could not read levels in page for col | exception | error | |
| Failed to complete multipart upload for key | exception | error | s3, multipart-upload, recovery, lifecycle-rules, commit, flink |
| The end timestamp of an event-time window cannot become… | exception | error | flink, datastream-v2, windowing, session-windows, event-time, watermark, late-data |
| The quality of field type is incompatible with the request… | exception | error | parquet, schema, internal-invariant, flink |
| Trying to access closed classloader. Please check if you… | exception | error | classloader, memory-leak, session-cluster, shutdown |
| Cannot commit empty multipart upload for object | exception | error | multipart-upload, writer, recoverable-state, programming-error, s3, flink |
| Cannot execute operator | exception | error | collection-executor, operator-type, local-execution, flink-core |
| Cannot handle operator type | exception | error | collection-executor, iteration, operator-type, dynamic-path, flink-core |
| Unsupported type of window strategy | exception | critical | flink, datastream-v2, windowing, window-strategy, job-translation, version-mismatch |
| Failed to read from input stream | exception | error | parquet, io, data-corruption, flink-formats |
| Could not clone serializer instance of class | exception | error | kryo, serialization, custom-serializer, flink-core |
| Could not execute application. | exception | critical | application-mode, program-execution, detached, class-loading |
| Could not determine TypeInformation for the OutputTag type… | validation | error | side-outputs, type-information, generics, flink-core |
| Python command line option detected but the flink-python… | exception | error | cli, python, classpath, module-missing |
| Unable to clone instance of | exception | error | serialization, cloning, classloader, runtime |
| DistributedCache supports only local files for Collection… | exception | error | distributed-cache, collection-executor, local-files, filesystem, flink-core |
| The end timestamp of a processing-time window cannot become… | exception | error | flink, datastream-v2, windowing, session-windows, processing-time, backpressure |
| Could not serialize serializer into the configuration. | exception | error | serialization, deserialization, classloader, version-mismatch |
| Currently, filesystem sink doesn't support setting… | validation | error | table-sink, parallelism, changelog-mode, validation, flink |
| CRT transport requested (s3.crt.enabled=true) but the… | exception | critical | s3, crt, classpath, plugins, deployment, flink |
| Field is null, but expected to hold a value. | exception | error | tuple, null-field, serialization, data-quality, typeutils |
| operation interrupted | exception | warning | filesystem, windows, interruption, concurrency |
| Unrecognized version or corrupt state | exception | error | serialization, local-filesystem, checkpoint-restore, version-mismatch |
| Fail to deserialize at field | exception | error | csv, parsing, field-conversion, dirty-data |
| No valid command-line found. | exception | error | cli, deployment, configuration, startup |
| Could not parse value for key | validation | error | configuration, parse-error, sensitive-keys, security, flink-core |
| unrecognized compatibility type. | exception | error | serialization, state, schema-compatibility, internal-invariant, version-mismatch |
| Invalid time zone for | validation | error | table-factory, time-zone, validation, partition-commit, flink |
| Concurrent access to KryoSerializer. Thread 1 | exception | error | thread-safety, kryo, concurrency, flink-core |
| In progress file( ) not exists. | exception | error | flink, hadoop, filesystem, file-sink, commit, exactly-once |
| The implementation of the | exception | error | serialization, closure-cleaner, inner-class, user-function |
| fs.s3.aws.credentials.provider is set but contains no valid… | validation | error | configuration, credentials, s3, flink-conf, flink |
| Field is accessed for a key, but out of bounds in the… | exception | error | tuple, key-position, out-of-bounds, comparator, partitioning |
| Could not create the Dispatcher rpc endpoint. | exception | critical | dispatcher, rpc, application-mode, startup, high-availability |
| Missing JobId | validation | error | cli, job-management, user-input |
| Unknown "op" value " ". The Debezium Avro message is | exception | error | debezium, avro, schema-registry, kafka, serialization |
| Could not register security manager due to no permission to… | validation | error | security, configuration, flink-core, java-17, startup |
| Can not register process function transformation translator. | exception | critical | datastream-v2, classpath, linkage, startup, version-mismatch |
| Job failed | exception | error | job-execution, job-client, runtime-error |
| An error occurred while copying the file. | exception | error | distributed-cache, filesystem, io, taskmanager |
| Could not instantiate type | exception | error | reflection, instantiation, accessibility, jpms |
| Serializer not yet initialized. | exception | error | state-descriptor, serializer, lazy-initialization, default-value |
| Cannot instantiate class. | exception | error | pojo, serialization, reflection, type-system, state-restore |
| DynamicFileSplitEnumerator only supports batch execution. | exception | error | batch-mode, dynamic-filtering, checkpointing, file-source, flink |
| Failed to instantiate credentials provider | validation | error | credentials, reflection, configuration, aws-sdk-v2, s3, flink |
| Application Mode not supported by standalone deployments. | exception | error | deployment, standalone, application-mode, unsupported-operation |
| This source reader does not support pausing or resuming… | exception | warning | source, watermark-alignment, source-api |
| Failed to async upload object for key | exception | error | s3, transfer-manager, async, network, retry, flink |
| Error while waiting for job to be initialized | exception | critical | parquet, io, encoding, data-corruption |
| Serialized data with version | exception | error | serialization, version-mismatch, gcs, checkpoint-restore |
| Unexpected serializer type. | exception | error | state, serialization, map-state, serializer |
| Could not load class for serialization config | validation | error | serialization, configuration, classpath, class-loading |
| Can't deserialize Debezium Avro message. | exception | error | debezium, avro, wrapper-exception, serialization, diagnostics |
| Error: Invalid number of samples | exception | error | input-format, delimited, sampling, statistics, configuration, runtime-exception |
| Parquet with case insensitive mode should have no duplicate… | exception | error | parquet, schema, case-insensitive, flink |
| The cpu cores and task heap memory are required when… | exception | error | slot-sharing-group, resource-configuration, validation, flink-core |
| No cluster id was specified. Please specify a cluster to… | exception | error | cli, deployment, cluster-connection, configuration |
| Error parsing YAML configuration. | exception | error | configuration, io, permissions, startup, flink-core |
| No JAR with manifest attribute for entry class | exception | error | |
| Could not duplicate SimpleVersionedSerializer. | exception | error | serialization, type-serializer, classloader, java-serialization |
| Tuple type expected but was | exception | error | type-information, tuple, pojo, type-extractor, validation |
| Class does not implement AwsCredentialsProvider | validation | error | configuration, credentials, aws-sdk-v2, migration, s3, flink |
| Failed to create enumerator for sourceIndex= | exception | error | hybrid-source, checkpoint-restore, source-enumerator, flink |
| Could not find required Avro dependency. | exception | error | kryo, avro, missing-dependency, flink-core |
| Invalid time unit: | exception | error | parquet, timestamp, version-conflict, flink-formats |
| ReduceFunction of ReducingState can not be a RichFunction. | exception | error | state, reducing-state, rich-function, validation |
| This JobSubmissionResult is not a JobExecutionResult. | exception | error | job-result, type-mismatch, execution, classcast |
| POJO type expected but was | exception | error | type-system, pojo, type-extraction, invalid-types-exception |
| Could not initialize basic comparator | exception | error | type-information, comparator, reflection, basic-type |
| get descriptors error! | exception | error | protobuf, classpath, reflection, configuration |
| Unknown class resolution order | validation | error | classloader, configuration, internal-api |
| No ClusterClientFactory found. If you were targeting a Yarn… | exception | critical | deployment, service-loader, classpath, configuration |
| Undefined compatibility type. | exception | error | serialization, state, schema-compatibility, internal-invariant, custom-serializer |
| AWS region could not be determined. Set 's3.region' in… | validation | error | configuration, region, s3, minio, aws-sdk-v2, flink |
| Row arity of reuse ( ) does not match this serializer's… | exception | error | row, serializer, arity-mismatch, deserialization, reuse |
| Unsupported time type | validation | critical | flink, datastream-v2, windowing, window-strategy, enum, version-mismatch, job-translation |
| Could not parse value | validation | error | configuration, parse-error, yaml, flink-core |
| The given buffer is neither an array-backed heap… | exception | error | memory, deserialization, bytebuffer, api-misuse |
| Failed to start multipart upload for key | exception | error | s3, multipart-upload, iam, permissions, network, flink |
| Unable to serialize record | exception | error | serialization, io, type-mismatch, schema |
| Unable to deserialize VARIANT value. | exception | error | json, variant, deserialization, flink-json |
| Record serialization with leading normalized keys not… | exception | error | row, comparator, unsupported-operation, normalized-key, dataset-api |
| The type ' ' is not supported for the CSV input format. | exception | error | flink, csv, input-format, type-system, field-parser |
| Cannot compare specified resources with UNKNOWN resources. | exception | error | resource-spec, scheduling, unknown-sentinel, flink-core |
| Corrupted data to deserialize | exception | critical | async-sink, state-serialization, corruption, checkpoint-restore |
| Could not initialize primitive | exception | error | type-information, comparator, reflection, primitive-array |
| MemorySegment can be freed only once! | exception | error | memory, lifecycle, flink-core, double-free |
| SimpleVersionedSerializerWrapper is not meant to be used as… | exception | error | type-serializer, state-backend, unsupported-operation, api-misuse |
| Field is null, but expected to hold a key. | exception | error | tuple, null-key, comparator, reference-compare, data-quality |
| Error during Java serialization. | exception | error | serialization, kryo, java-serialization, flink-core |
| This type ( ) cannot be used as key. | exception | error | keys, type-system, keyby, flink-core |
| Method createProcTime isn't supported in… | exception | error | filesystem-connector, partition-commit, configuration, internal-api |