ErrLookup › apache/flink
apache/flink
Apache Flink · Java · 10,282 source files
Analyzed at 2f3c205e92 on 2026-08-14. 1239 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Error while waiting for job to be initialized | exception | critical | parquet, io, encoding, data-corruption |
| Translator {} cannot translate the given pipeline {}. | exception | critical | parquet, encoding, dictionary, data-corruption |
| Could not get job jar and dependencies from JAR file: {} | exception | error | parquet, encoding, unsupported-feature |
| Could not build the program from JAR file: {} | exception | critical | parquet, rle, io, data-corruption |
| Failed to retrieve job list. | exception | error | parquet, encoding, unsupported-feature |
| Could not cancel job {}. | exception | critical | parquet, io, data-corruption, fixed-len-byte-array |
| Missing JobID. Specify a JobID to cancel a job. | validation | critical | parquet, boolean, io, data-corruption |
| Missing JobID. Specify a Job ID to trigger a savepoint. | validation | critical | parquet, nested, dictionary, data-corruption |
| Could not stop with a savepoint job "{}". | exception | error | parquet, nested, type-mismatch, unsupported-feature |
| Could not stop with a detached savepoint job "{}". | exception | error | parquet, nested, dictionary, type-mismatch |
| Failed to trigger a savepoint for the job {}. | exception | error | parquet, nested, type-mismatch, vector |
| Triggering a detached savepoint for the job {} failed. | exception | critical | parquet, nested, dictionary, data-corruption |
| Failed to dispose the savepoint '{}'. | exception | critical | parquet, nested, io, data-corruption |
| Missing JobID. Specify a Job ID to manipulate a checkpoint. | validation | critical | parquet, nested, page-v1, data-corruption |
| Failed to trigger a checkpoint for the job {}. | exception | critical | parquet, nested, page-v2, data-corruption |
| JAR file does not exist: {} | exception | critical | parquet, nested, rle, levels, data-corruption |
| JAR file is not a file: {} | exception | error | parquet, timestamp, type-mismatch, double |
| Missing JobId | validation | error | parquet, timestamp, type-mismatch, dictionary, double |
| No cluster id was specified. Please specify a cluster to whi | exception | error | cli, deployment, cluster-connection, configuration |
| The configuration directory '{}', specified in the '{}' envi | exception | critical | cli, configuration, environment, startup |
| The configuration directory was not specified. Please specif | exception | critical | cli, configuration, environment, startup |
| No valid command-line found. | exception | error | cli, deployment, configuration, startup |
| Missing JobId | validation | error | cli, job-management, user-input |
| Bad syntax for classpath: {} | validation | error | cli, classpath, user-input, configuration |
| The parallelism must be a positive number: {} | validation | error | cli, configuration, user-input |
| Java program should be specified a JAR file. | validation | error | cli, user-input, job-submission |
| Python command line option detected but the flink-python mod | exception | error | cli, python, classpath, module-missing |
| Job failed | exception | error | job-execution, job-client, runtime-error |
| Multiple compatible client factories found for: {}. | exception | error | deployment, service-loader, configuration, classpath |
| No ClusterClientFactory found. If you were targeting a Yarn | exception | critical | deployment, service-loader, classpath, configuration |
| Couldn't retrieve standalone cluster | exception | error | deployment, standalone, rest, network, cluster-connection |
| Can't deploy a standalone cluster. | exception | error | deployment, standalone, unsupported-operation |
| Application Mode not supported by standalone deployments. | exception | error | deployment, standalone, application-mode, unsupported-operation |
| Cannot terminate a standalone cluster. | exception | warning | deployment, standalone, unsupported-operation |
| Could not create the Dispatcher rpc endpoint. | exception | critical | dispatcher, rpc, application-mode, startup, high-availability |
| Invalid cluster id "%s". The expected format is [0-9a-fA-F]{ | validation | error | application-mode, configuration, cluster-id, high-availability |
| Could not execute application. | exception | critical | application-mode, program-execution, detached, class-loading |
| Cannot deserialize and unwrap accumulators properly. | exception | warning | accumulators, embedded, application-mode, serialization, classloader |
| No JAR found on classpath. Please provide a JAR explicitly. | exception | error | |
| Multiple JAR archives with entry classes found on classpath. | exception | error | |
| No JAR with manifest attribute for entry class | exception | error | |
| Multiple JARs with manifest attribute for entry class: %s | exception | error | |
| Failed to get user jar file from blob | exception | error | |
| Jar file %s does not exist | exception | error | |
| Failed to create PackagedProgram for application %s | exception | error | |
| Failed to extract '%s' as URLs. Provided value: %s | exception | error | |
| No exception thrown although the job execution was not succe | exception | error | |
| The Job Status cannot be requested when in Web Submission. | exception | error | |
| Cancelling the job is not supported by the Job Client when i | exception | error | |
| Stop with Savepoint is not supported by the Job Client when | exception | error | |
| A savepoint cannot be taken through the Job Client when in W | exception | error | |
| The Accumulators cannot be fetched through the Job Client wh | exception | error | |
| The Job Result cannot be fetched through the Job Client when | exception | error | |
| An error occurred while extracting the user classpath. | exception | error | |
| Could not load the provided entrypoint class. | exception | error | |
| Base job ID %s is not found in the recovered jobs. | validation | error | |
| Exhausted all job IDs for job name: %s | exception | error | |
| Job ID %s is not derived from the base job ID %s. | validation | error | |
| Cannot deserialize and unwrap accumulators properly. | exception | error | accumulator, deserialization, classpath, minicluster |
| The given program class does not have a main(String[]) metho | exception | error | packaged-program, main-method, jar, entry-point |
| Error while getting the program description | exception | warning | packaged-program, program-description, manifest, job-plan |
| URL is invalid. This should not happen. | exception | error | packaged-program, url, filesystem, defensive |
| Could not look up the main(String[]) method from the class % | exception | error | packaged-program, reflection, security, main-method |
| The class %s must be public. | exception | error | packaged-program, main-method, access-modifiers |
| The class %s has no main(String[]) method. | exception | error | packaged-program, main-method, invocation |
| The class %s declares a non-static main method. | exception | error | packaged-program, main-method, static-modifier |
| The class %s declares a non-public main method. | exception | error | packaged-program, main-method, access-modifiers |
| Could not invoke the main method, arguments are not matching | exception | error | packaged-program, invocation, reflection, argument-mismatch |
| Access to the main method was denied: {e.getMessage()} | exception | error | packaged-program, invocation, module-system, access-denied |
| The main method caused an error: {exceptionInMethod.getMessa | exception | error | packaged-program, invocation, user-code-error, main-method |
| An error occurred while invoking the program's main method: | exception | error | packaged-program, invocation, linkage-error, bytecode |
| Invalid file path '{jarFile.getPath()}' | exception | error | packaged-program, jar, uri, path |
| Error while opening jar file '{jarFile.getPath()}'. {ioex.ge | exception | error | packaged-program, jar, io, corruption |
| The Manifest in the jar file could not be accessed '{jarFile | exception | error | packaged-program, jar, manifest, io, corruption |
| No manifest found in jar file '{jarFile.getPath()}'. The man | exception | error | packaged-program, jar, manifest, entry-point |
| Neither a '{MANIFEST_ATTRIBUTE_MAIN_CLASS}', nor a '{MANIFES | exception | error | packaged-program, jar, manifest, main-class, entry-point |
| Could not close the JAR file: {t.getMessage()} | exception | warning | packaged-program, jar, io, resource-cleanup, finally |
| The jar file path is invalid. | validation | error | jar, packaged-program, path-validation, uri |
| The program's entry point class '{className}' was not found | exception | error | packaged-program, class-loading, class-not-found, jar |
| The program's entry point class '{className}' threw an error | exception | critical | packaged-program, class-loading, static-initializer, initialization |
| The program's entry point class '{className}' could not be l | exception | critical | packaged-program, class-loading, linkage-error, dependency, classpath |
| The program's entry point class '{className}' caused an exce | exception | critical | packaged-program, class-loading, catch-all, initialization |
| Unknown I/O error while extracting contained jar files. | exception | error | packaged-program, jar, io, extraction, temp-files |
| An I/O error occurred while extracting nested library '{inpu | exception | error | packaged-program, io, extraction, disk-space, temp-files |
| An I/O error occurred while creating temporary file to extra | exception | error | packaged-program, io, temp-files, filesystem, permissions |
| {e.getMessage()} | exception | error | packaged-program, jar, validation, io |
| Cannot access jar file{t.getMessage() == null ? "." : ": " + | exception | error | packaged-program, jar, security, catch-all, validation |
| The jarFile and entryPointClassName can not be null at the s | validation | error | packaged-program, builder, validation, argument |
| Exception encountered during finding the flink-python jar. T | exception | critical | python, packaged-program-utils, filesystem, environment, flink-home |
| Found {optJarPath.size()} %s jar. | exception | critical | python, packaged-program-utils, filesystem, duplicate-jars, flink-home |
| URL is invalid. This should not happen. | exception | warning | python, packaged-program-utils, url, uri, internal |
| Cannot have more than {streamingJobCountLimit} streaming job | exception | error | stream-context-environment, job-limit, streaming, application-mode |
| Cannot have more than {jobCountLimit} jobs in a single envir | exception | error | stream-context-environment, job-limit, application-mode |
| Not allowed configuration change(s) were detected:\n - {erro | exception | error | stream-context-environment, configuration, validation, mutated-config, security |
| Corrupt artifact fetching state. | exception | warning | artifact-fetch, internal, unreachable, assertion |
| Artifact fetching from raw HTTP endpoints are disabled. Set | validation | error | artifact-fetch, security, http, configuration, scheme |
| Failed to create parent(s) for given base dir: %s | exception | error | artifact-utils, filesystem, permissions, io, directory |
| Failed to serialize ExecutionPlan. | exception | error | serialization, job-submission, rest-client, io |
| Failed to get the FileSystem of artifact {artifactFilePath}. | exception | error | filesystem, job-submission, distributed-cache, rest-client |
| Failed to submit ExecutionPlan. | exception | error | job-submission, rest-client, network, error-handling |
| {checkpointInfo.getFailureCause()} | exception | error | checkpoint, rest-client, async-operation |
| Failed to deserialize coordination response | exception | error | serialization, rest-client, operator-coordination, classloader |
| {savepointInfo.getFailureCause()} | exception | error | savepoint, rest-client, async-operation |
| Cannot deserialize and unwrap accumulators properly. | exception | error | accumulators, rest-client, serialization, classloader |
| {asynchronousOperationInfo.getFailureCause()} | exception | error | savepoint, rest-client, async-operation |
| Job %s is in state SUSPENDED | exception | warning | job-status, rest-client, suspended, recovery |
| Result for Job %s is UNKNOWN | exception | warning | job-result, rest-client, unknown-state, ha |
| Could not parse URL from {url} | exception | error | rest-client, leader-election, url-parsing, configuration |
| Cannot create empty classifier chain. | validation | error | async-sink, classifier, validation, programming-error |
| Wrong classifier chain; Circular chain of classifiers detect | validation | error | async-sink, classifier, cycle-detection, programming-error |
| Please override the method. | exception | critical | async-sink, missing-override, api-contract, programming-error |
| The request entry sent to the buffer was of size [%s], when | validation | error | async-sink, record-size, buffer, validation |
| Corrupted data to deserialize | exception | critical | async-sink, state-serialization, corruption, checkpoint-restore |
| The bytes are serialized with version %d, while this deseria | exception | critical | hybrid-source, state-serialization, version-mismatch, checkpoint-restore |
| Failed to close current reader | exception | error | hybrid-source, source-reader, resource-cleanup, source-transition |
| Failed to create reader | exception | error | hybrid-source, source-reader, initialization, source-transition |
| Failed to create enumerator for sourceIndex={currentSourceIn | exception | error | hybrid-source, checkpoint-restore, source-enumerator, flink |
| Invalid version %d | exception | error | serialization, checkpoint-restore, hybrid-source, version-mismatch, flink |
| Source fetch execution was interrupted | exception | warning | fetcher, interruption, shutdown, flink-source |
| SplitFetcher thread %d received unexpected exception while p | exception | error | fetcher, split-reader, runtime, flink-source |
| The thread was interrupted while waiting for a fetcher task. | exception | warning | fetcher, interruption, shutdown, flink-source |
| One or more fetchers have encountered exception | exception | error | fetcher-manager, error-propagation, runtime, flink-source |
| This split reader does not support pausing or resuming split | exception | error | watermark-alignment, split-reader, config, flink-source |
| exception in queue future completion | exception | error | blocking-queue, future, internal, flink-source |
| Invalid option %s. Must be a positive integer. | validation | error | config-validation, async-sink, options, flink |
| ${message} | validation | error | config-validation, boolean, properties, flink |
| Serializing the source elements failed: {e.getMessage()} | exception | error | serialization, type-information, from-elements, flink |
| Reached the end of the collection. This could be caused by i | exception | error | serialization, from-elements, data-generator, flink |
| Failed to deserialize an element from the source. If you are | exception | error | serialization, from-elements, deserialization, flink |
| {e.getMessage()} | exception | error | serialization, type-information, from-elements, output-type, flink |
| The collection contains a null element | validation | error | datagen, validation, null-check, constructor |
| The elements in the collection are not all subclasses of {vi | validation | error | datagen, type-system, validation, type-mismatch |
| The collection contains a null element | validation | error | datagen, validation, null-check, index-lookup, constructor |
| The elements in the collection are not all subclasses of {vi | validation | error | datagen, type-system, validation, type-mismatch, index-lookup |
| Serializing the source elements failed: {e.getMessage()} | exception | error | datagen, serialization, index-lookup, constructor |
| Reached the end of the collection. This could be caused by i | exception | error | datagen, serialization, deserialization, index-lookup, eof |
| Failed to deserialize an element from the source. If you are | exception | error | datagen, serialization, deserialization, custom-type, index-lookup |
| {e.getMessage()} | exception | error | datagen, serialization, index-lookup, constructor |
| Failed to open the GeneratorFunction | exception | error | datagen, source-reader, generator-function, lifecycle, test |
| A user-provided generator function threw an exception on thi | exception | error | datagen, generator-function, user-code, runtime, test |
| A user-provided generator function threw an exception on thi | exception | error | datagen, generator-function, user-code, runtime |
| Failed to open the GeneratorFunction | exception | error | datagen, source-reader, generator-function, lifecycle |
| Could not create writer state serializer. | exception | error | file-sink, filesystem, serializer, configuration, connectivity |
| Could not create committable serializer. | exception | error | file-sink, filesystem, serializer, configuration, connectivity |
| Unrecognized version or corrupt state: {version} | exception | error | file-sink, serialization, state-restore, version-mismatch, checkpoint |
| Corrupt data: Unexpected magic number %08X | exception | error | file-sink, serialization, data-corruption, state-restore, integrity-check |
| At least one trigger condition must be configured. | validation | error | file-sink, compaction, configuration, builder, validation |
| Committable to compact has no content. | exception | error | file-sink, compaction, internal, state-restore, defensive |
| Unexpected trigger result:{triggerResult} | exception | error | file-sink, compaction, internal, defensive, unreachable |
| DynamicFileSplitEnumerator only supports batch execution. | exception | error | batch-mode, dynamic-filtering, checkpointing, file-source, flink |
| The SplitChange type of %s is not supported. | exception | error | split-change, file-source-reader, unsupported-operation, flink |
| Cannot fetch from another split - no split remaining | exception | error | file-source-reader, split-exhaustion, io-exception, flink |
| The fetch size (%s) must be > 0, but is %d | exception | error | config, stream-format, fetch-size, illegal-config, flink |
| SimpleStreamFormat is not splittable, but found split end (% | exception | error | simple-stream-format, non-splittable, file-source, flink |
| Cannot find the partition value from path for partition: %s | exception | error | partition, metadata, file-path, bulk-format, flink |
| An IO error occurred while accessing the staging FileSystem. | exception | error | output-format, staging-directory, io-error, filesystem, flink |
| Exception in finalizeGlobal | exception | error | output-format, finalize-global, partition-commit, table-exception, flink |
| Exception in open | exception | error | output-format, open, partition-writer, table-exception, flink |
| Exception in writeRecord | exception | error | output-format, write-record, serialization, table-exception, flink |
| Exception in close | exception | error | output-format, close, partition-writer, table-exception, flink |
| Table options do not contain an option key '%s' for discover | validation | error | table-factory, format-option, validation, ddl, flink |
| Invalid time zone for '%s'. The value should be a Time Zone | validation | error | table-factory, time-zone, validation, partition-commit, flink |
| Could not find any format factory for identifier '%s' in the | validation | error | table-sink, format-factory, validation, classloader, flink |
| Streaming mode not support overwrite. | exception | error | table-sink, overwrite, streaming-mode, illegal-state, flink |
| Compaction reader not support DataStructure converter. | exception | error | table-sink, compaction-reader, data-structure-converter, unsupported-operation, flink |
| Can not find format factory. | exception | error | table-sink, format-factory, writer-creation, table-exception, flink |
| Currently, filesystem sink doesn't support setting paralleli | validation | error | table-sink, parallelism, changelog-mode, validation, flink |
| Could not find any format factory for identifier '%s' in the | validation | error | table-source, format-factory, validation, classloader, flink |
| Can not find format factory. | exception | error | |
| Fetch partitions fail. | exception | error | |
| Partition keys are: %s, incomplete partition spec: %s | exception | error | |
| Can not configure a 'metastore' partition commit policy for | validation | error | |
| Can not create new instance for custom class from %s | exception | error | |
| Unsupported policy: %s | exception | error | |
| Cannot find the partition value from path for partition: %s | exception | error | |
| Can not new instance for custom class from %s | exception | error | |
| Unsupported extractor kind: %s | exception | error | |
| Can not convert %s to type %s for partition value | exception | error | |
| Unsupported input message: %s | exception | error | |
| Unsupported input message: {value} | exception | error | |
| Exception in open | exception | error | |
| Exception in writeRecord | exception | error | |
| Exception in close | exception | error | |
| Exception in finish | exception | error | |
| Unsupported partition commit predicate: {trigger} | exception | error | |
| Unsupported partition commit trigger: {trigger} | exception | error | |
| Checkpoint(%d) has not been snapshot. The watermark informat | exception | error | |
| Method createProcTime isn't supported in PartitionTimeCommit | exception | error | filesystem-connector, partition-commit, configuration, internal-api |
| Method currentProcTime isn't supported in PartitionTimeCommi | exception | error | filesystem-connector, partition-commit, configuration, internal-api |
| Method currentWatermark isn't supported in ProcTimeCommitTri | exception | error | filesystem-connector, partition-commit, configuration, internal-api |
| Unsupported input message: {value} | exception | error | filesystem-connector, compaction, internal-api, class-loading |
| Compaction file not exist: {path} | exception | error | filesystem-connector, compaction, filesystem, io |
| Bulk Part Writers do not support "pause and resume" operatio | exception | error | file-sink, bulk-writer, checkpoint, internal-api |
| Writer has already been opened as {writeType} type, but tryi | exception | error | file-sink, output-stream-writer, internal-api |
| can not recover from the pendingFileRecoverable | exception | error | file-sink, recovery, state-compatibility, internal-api |
| Unrecognized version or corrupt state: {version} | exception | error | file-sink, serialization, state-compatibility, checkpoint |
| Corrupt data: Unexpected magic number %08X | exception | error | file-sink, serialization, corruption, checkpoint |
| Unrecognized version or corrupt state: {version} | exception | error | file-sink, serialization, bucket-assigner, checkpoint |
| Unable to instantiate the hadoop input format | exception | error | hadoop-compatibility, input-format, classpath, class-loading |
| Unable to find key class. | exception | error | hadoop-compatibility, input-format, classpath, class-loading |
| Unable to find value class. | exception | error | hadoop-compatibility, input-format, classpath, class-loading |
| Task id too large. | exception | error | hadoop-compatibility, output-format, parallelism, configuration |
| Unable to instantiate the hadoop output format | exception | error | hadoop-compatibility, output-format, classpath, class-loading |
| Hadoop input split must not be null | exception | error | hadoop-compatibility, input-split, null-check, internal-api |
| Hadoop JobConf must not be null when input split is configur | exception | error | hadoop-compatibility, input-split, null-check, internal-api |
| Unable to instantiate Hadoop InputSplit | exception | critical | hadoop, mapred, serialization, classloader, input-split |
| Could not get KeyValue pair. | exception | error | hadoop, mapreduce, input-format, interrupted, record-reader |
| Could not get Splits. | exception | error | hadoop, mapreduce, input-format, splits, interrupted |
| Could not create RecordReader. | exception | error | hadoop, mapreduce, record-reader, interrupted, task-open |
| Could not fetch next KeyValue pair. | exception | error | hadoop, mapreduce, record-reader, interrupted, iteration |
| Unable to instantiate the hadoop input format | exception | critical | hadoop, mapreduce, serialization, classloader, input-format |
| Unable to find key class. | exception | critical | hadoop, mapreduce, serialization, classloader, key-class |
| Unable to find value class. | exception | critical | hadoop, mapreduce, serialization, classloader, value-class |
| Could not write Record. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| Task id too large. | exception | error | hadoop, mapreduce, output-format, parallelism, task-id |
| Could not create RecordWriter. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| Could not close RecordReader. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| Unable to instantiate the hadoop output format | exception | critical | hadoop, mapreduce, serialization, classloader, output-format |
| Hadoop input split must not be null | validation | error | hadoop, mapreduce, validation, constructor, input-split |
| InputSplit must implement Writable interface. | validation | error | hadoop, mapreduce, validation, writable, input-split |
| Unable to instantiate the Hadoop InputSplit | exception | critical | hadoop, mapreduce, serialization, classloader, input-split |
| Cannot create Comparator for {typeClass.getCanonicalName()}. | exception | error | hadoop, type-info, comparator, writable, keyed |
| The given class is no subclass of {Writable.class.getName()} | validation | error | hadoop, type-info, validation, writable, type-extraction |
| Mapper may not be null. | validation | error | hadoop, mapred, validation, constructor, mapper |
| JobConf may not be null. | validation | error | hadoop, mapred, validation, constructor, jobconf |
| Reducer may not be null. | validation | error | hadoop-compatibility, mapred, null-check, constructor |
| JobConf may not be null. | validation | error | hadoop-compatibility, mapred, null-check, constructor |
| Cannot parse ApplicationID from "{hexString}". The expected | validation | error | application-id, parsing, hex, validation |
| JobStatus {jobStatus} does not have a corresponding Applicat | validation | error | application-state, job-status, terminal, state-machine |
| Parallelism must be at least one, or ExecutionConfig.PARALLE | validation | error | parallelism, execution-config, validation, config |
| Cannot parse JobID from "{hexString}". The expected format i | validation | error | job-id, parsing, hex, validation |
| This JobSubmissionResult is not a JobExecutionResult. | exception | error | job-result, type-mismatch, execution, classcast |
| Execution config has not been set properly for this plan | exception | error | plan, execution-config, optimizer, null-check |
| cache file {name}already exists! | exception | error | distributed-cache, plan, duplicate, registration |
| Unknown restart strategy {restartStrategyName}. | validation | error | restart-strategy, config, parsing, description |
| The accumulator object '{name}' was created with two differe | exception | error | accumulator, type-mismatch, merge, naming |
| The accumulator object '{name}' was created with two differe | exception | error | accumulator, classloader, isolation, fat-jar |
| The merged accumulator must be AverageAccumulator. | validation | error | accumulator, average, merge, type-mismatch |
| Failed to serialize value '{value}' | exception | error | accumulator, serialization, kryo, type-serializer |
| Name and aggregator must not be null | validation | error | aggregator, iteration, null-check, registration |
| An aggregator is already registered under the given name. | exception | error | aggregator, iteration, duplicate, registration |
| Name, aggregator, or convergence criterion must not be null | validation | error | aggregator, iteration, convergence, null-check |
| name must not be null | validation | error | distributed-cache, null-check, task, runtime-context |
| File with name '${name}' is not available. Did you forget to | validation | error | distributed-cache, registration, task, name-mismatch |
| An error occurred while copying the file. | exception | error | distributed-cache, filesystem, io, taskmanager |
| Error while getting the file registered under '${name}' from | exception | error | distributed-cache, interruption, concurrency, taskmanager |
| The runtime context has not been initialized. | exception | error | rich-function, runtime-context, lifecycle, user-error |
| This stub is not part of an iteration step function. | exception | error | rich-function, iteration, runtime-context, misuse |
| The accumulator '${name}' already exists and cannot be added | exception | error | accumulator, runtime-context, duplicate, user-error |
| Cannot create accumulator ${accumulatorClass.getName()} | exception | error | accumulator, reflection, runtime-context, user-error |
| This state is only accessible by functions executed on a Key | exception | error | keyed-state, state, valuestate, runtime-context, user-error |
| The broadcast variable with name '${name}' is not a List. A | exception | error | broadcast-variable, runtime-context, type-mismatch, user-error |
| The broadcast variable with name '${name}' has not been set. | validation | error | broadcast-variable, runtime-context, missing-config, user-error |
| Do not support external resource in current environment | exception | error | external-resource, gpu, runtime-context, unsupported-operation, local-execution |
| The block size parameter must be set and larger than 0. | validation | error | input-format, binary, block-size, validation, illegal-argument |
| Currently only block sizes up to Integer.MAX_VALUE are suppo | exception | error | input-format, binary, block-size, limit, unsupported-operation |
| You must have forgotten to call open() on your input format. | exception | error | input-format, binary, lifecycle, checkpoint, open |
| Delimiter must not be null | validation | error | input-format, delimited, delimiter, validation, illegal-argument |
| Line length limit must be at least 1. | validation | error | input-format, delimited, line-length-limit, validation, illegal-argument |
| Buffer size must be at least 2. | validation | error | input-format, delimited, buffer-size, validation, illegal-argument |
| Number of line samples must not be negative. | validation | error | input-format, delimited, sampling, validation, illegal-argument |
| Error: Invalid number of samples: ${numSamples} | exception | error | input-format, delimited, sampling, statistics, configuration, runtime-exception |
| Buffer size must be greater than length of delimiter. | validation | error | input-format, delimited, buffer-size, delimiter, validation, illegal-argument |
| The record length exceeded the maximum record length (${line | exception | error | input-format, delimited, record-length, delimiter, ioexception, data-quality |
| File path cannot be null. | validation | error | input-format, file-path, validation, illegal-argument |
| Could not create a valid URI from the given file path name: | exception | error | input-format, file-path, uri, path-parsing, runtime-exception |
| File path must not be null. | exception | error | input-format, file-path, validation, illegal-argument |
| At least one file path must be specified. | exception | error | input-format, file-path, validation, illegal-argument |
| The minimum split size cannot be negative. | exception | error | input-format, split-size, validation, illegal-argument |
| The desired number of splits must be positive or -1 (= don't | exception | error | input-format, num-splits, validation, illegal-argument |
| The timeout for opening the input splits must be positive or | exception | error | input-format, timeout, validation, illegal-argument |
| File path was not specified in input format or configuration | exception | error | input-format, file-path, configuration, lifecycle, illegal-argument |
| Number of input splits has to be at least 1. | exception | error | flink, file-input, input-splits, parallelism, configuration |
| The given offset is not contained in the any block. | exception | error | flink, file-input, hdfs, block-location, metadata |
| Error opening the Input Split {} [{},{}]: {} | exception | error | flink, file-input, ioexception-wrapper, filesystem, compression |
| Input opening request timed out. Opener was {} alive. Stack | exception | error | flink, file-input, timeout, filesystem, s3, hdfs, performance |
| Output file path may not be null. | exception | error | flink, file-output, null-check, configuration |
| TaskNumber: {}, numTasks: {} | exception | error | flink, file-output, parallelism, validation, testing |
| The file path is null. | exception | error | flink, file-output, null-check, lifecycle, testing |
| Output path '{}' could not be initialized. Canceling task... | exception | error | flink, file-output, local-fs, write-mode, overwrite |
| Output directory '{}' could not be created. Canceling task.. | exception | error | flink, file-output, local-fs, directory, write-mode |
| Output path could not be initialized. | exception | error | flink, file-output, distributed-fs, hdfs, s3, write-mode |
| Output directory could not be created. | exception | error | flink, file-output, distributed-fs, hdfs, directory, write-mode |
| Delimiter must not be null | exception | error | flink, csv, input-format, null-check, configuration |
| Field types must not be null. | exception | error | flink, csv, input-format, null-check, schema |
| The type '{}' is not supported for the CSV input format. | exception | error | flink, csv, input-format, type-system, field-parser |
| Field indices must not be smaller than zero. | exception | error | flink, csv, input-format, validation, field-index |
| Missing type for included field {}. | exception | error | flink, csv, input-format, schema, validation |
| Type for included field {} should not be null. | exception | error | flink, csv, input-format, null-check, schema |
| No parser available for type '{}'. | exception | error | csv, input-format, type-system, runtime |
| Row too short: {} | exception | error | csv, input-format, data-quality, parsing |
| Line could not be parsed: '{}' ParserError {} Expect field | exception | error | csv, input-format, data-quality, parsing |
| Line could not be parsed: '{}' Expect field types: {} in fi | exception | error | csv, input-format, data-quality, parsing |
| The positions and types must be of the same length | exception | error | csv, input-format, validation, api-misuse |
| The field ({} is invalid. | exception | error | csv, input-format, validation, api-misuse |
| The type {} is invalid (null) | exception | error | csv, input-format, validation, api-misuse |
| The position {} occurs multiple times. | exception | error | csv, input-format, validation, api-misuse |
| The field ({}) is invalid. | validation | error | csv, input-format, validation, api-misuse |
| The positions must be strictly increasing (no permutations a | validation | error | csv, input-format, validation, api-misuse |
| Number of input splits has to be at least 1. | validation | error | input-format, parallelism, configuration, runtime |
| Wrapped InputStream: cannot search backwards. | exception | error | io, input-stream, seek, filesystem |
| Unexpected EOF during forward seek. | exception | error | io, input-stream, eof, filesystem |
| Write record failed | exception | error | output-format, async, io, error-handling |
| The underlying input format to this ReplicatingInputFormat i | exception | error | input-format, runtime-context, api-misuse, broadcast |
| The runtime context has not been initialized yet. Try access | exception | error | input-format, runtime-context, lifecycle, api-misuse |
| The runtime context has not been initialized yet. Try access | exception | error | lifecycle, runtime-context, output-format, flink-core |
| Failed to acquire %d out of %d permits to send value in %s. | exception | warning | async-sink, rate-limiting, semaphore, timeout, backpressure |
| The broadcast input name may not be null. | validation | error | broadcast-variable, null-check, flink-core, internal-api |
| The broadcast input root operator may not be null. | validation | error | broadcast-variable, null-check, flink-core, internal-api |
| Cannot execute operator {} | exception | error | collection-executor, operator-type, local-execution, flink-core |
| The data sink {} has no input. | validation | error | data-sink, plan-validation, collection-executor, flink-core |
| The unary operation {} has no input. | validation | error | unary-operator, plan-validation, collection-executor, flink-core |
| The binary operation {} has no first input. | validation | error | binary-operator, join, plan-validation, collection-executor, flink-core |
| The binary operation {} has no second input. | validation | error | binary-operator, join, plan-validation, collection-executor, flink-core |
| The iteration {} has no input (initial partial solution). | validation | error | iteration, bulk-iteration, plan-validation, collection-executor, flink-core |
| The iteration {} has no next partial solution defined (is no | validation | error | iteration, bulk-iteration, plan-validation, closewith, flink-core |
| The delta iteration {} has no initial solution set. | validation | error | iteration, delta-iteration, plan-validation, collection-executor, flink-core |
| The delta iteration {} has no initial workset. | validation | error | iteration, delta-iteration, plan-validation, collection-executor, flink-core |
| The iteration {} has no solution set delta defined (is not c | validation | error | iteration, delta-iteration, plan-validation, closewith, flink-core |
| The iteration {} has no workset defined (is not closed). | validation | error | iteration, delta-iteration, plan-validation, closewith, flink-core |
| Cannot handle operator type {} | exception | error | collection-executor, iteration, operator-type, dynamic-path, flink-core |
| DistributedCache supports only local files for Collection En | exception | error | distributed-cache, collection-executor, local-files, filesystem, flink-core |
| The output size cannot be smaller than zero. | validation | error | compiler-hints, validation, argument-check, flink-core |
| The output cardinality cannot be smaller than zero. | validation | error | compiler-hints, validation, argument-check, flink-core |
| The size of produced records must be positive. | validation | error | compiler-hints, validation, argument-check, flink-core |
| The filter factor cannot be smaller than zero. | validation | error | flink-core, compiler-hints, optimizer, dataset-api, validation |
| Target field {} was added twice to input {} | validation | error | flink-core, semantic-annotations, forwarded-fields, two-input, dataset-api |
| Local output sorting does not support type {inputType} yet. | exception | error | flink-core, data-sink, collection-execution, sorting, type-system |
| Input format may not be null. | exception | error | flink-core, data-source, constructor-null-check, input-format |
| The number of specified keys is different. | exception | error | flink-core, keys, join, cogroup, dataset-api, type-compatibility |
| {typeInformation} and {typeInformation2} are not compatible | exception | error | flink-core, keys, join, type-compatibility, dataset-api |
| Key extractor must not be null. | exception | error | flink-core, keys, key-selector, null-check |
| Key type must not be null. | exception | error | flink-core, keys, type-information, null-check, key-selector |
| Return type {keyType} of KeySelector {keyExtractor.getClass( | exception | error | flink-core, keys, key-selector, type-information, validation |
| Custom partitioners can only be used with keys that have one | exception | error | flink-core, keys, custom-partitioner, partitioning, validation |
| The partitioner is incompatible with the key type. Partition | exception | error | flink-core, keys, custom-partitioner, type-compatibility, validation |
| Specifying keys via field positions is only valid for tuple | exception | error | flink-core, keys, expression-keys, tuple, type-system |
| Tuple size must be greater than 0. Size: {type.getArity()} | exception | error | flink-core, keys, expression-keys, tuple, validation |
| The grouping fields must not be empty. | exception | error | flink-core, keys, expression-keys, validation, grouping |
| This type ({ffd.getType()}) cannot be used as key. | exception | error | flink-core, keys, expression-keys, type-system, validation |
| Expression key may not be null. | exception | error | flink-core, keys, expression-keys, null-check, validation |
| Unable to extract key from expression '{keyExpr}' on key {cT | exception | error | flink-core, keys, expression-keys, field-resolution, validation |
| This type ({field.getType()}) cannot be used as key. | exception | error | keys, type-system, keyby, flink-core |
| This type ({type}) cannot be used as key. | exception | error | keys, type-system, keyby, flink-core |
| Field expression must be equal to '*' or '_' for non-composi | exception | error | keys, type-system, keyby, flink-core |
| Tuple position is out of range: {fieldPos} | exception | error | keys, sorting, index-out-of-bounds, tuple, flink-core |
| Field expression must be equal to '*' or '_' for atomic type | exception | error | keys, sorting, type-system, flink-core |
| Tuple position is out of range: {f} | exception | error | keys, index-out-of-bounds, validation, tuple, flink-core |
| Could not determine type information from inputs. | exception | error | operators, null-check, union, flink-core |
| The input may not contain null elements. | exception | error | operators, null-check, union, flink-core |
| The key index must not be negative. | exception | error | ordering, validation, index, flink-core |
| An ordering must not be created with a NONE order. | exception | error | ordering, validation, flink-core |
| {index} | exception | error | ordering, index-out-of-bounds, flink-core |
| Cannot compare specified resources with UNKNOWN resources. | exception | error | resource-spec, scheduling, unknown-sentinel, flink-core |
| Target field {} was added twice. | exception | error | semantic-properties, forwarded-field, annotation, flink-core |
| Cannot modify forwarded fields | exception | error | semantic-properties, immutable, unsupported-operation, flink-core |
| The cpu cores and task heap memory are required when specify | exception | error | slot-sharing-group, resource-configuration, validation, flink-core |
| Operator producing the next partial solution must not be nul | exception | error | bulk-iteration, null-check, dataset-api, flink-core |
| The number of iterations must be at least one. | exception | error | bulk-iteration, validation, iteration-count, dataset-api, flink-core |
| Operator for initial partial solution is not set. | exception | error | bulk-iteration, validation, missing-input, dataset-api, flink-core |
| Operator producing the next version of the partial solution | exception | error | bulk-iteration, validation, missing-step-function, invalid-program, dataset-api, flink-core |
| No termination condition is set (neither fix number of itera | exception | error | bulk-iteration, validation, termination, invalid-program, dataset-api, flink-core |
| The BulkIteration meta operator cannot have broadcast inputs | exception | error | bulk-iteration, broadcast-variable, unsupported-operation, dataset-api, flink-core |
| Input type of coGroup must be one of composite types or atom | exception | error | cogroup, type-system, comparator, invalid-program, dataset-api, flink-core |
| Input types of coGroup must be composite types. | exception | error | cogroup-raw, type-system, comparator, invalid-program, dataset-api, flink-core |
| The DeltaIteration meta operator cannot have broadcast input | exception | error | delta-iteration, broadcast-variable, unsupported-operation, dataset-api, flink-core |
| Input type of GroupCombine must be one of composite types or | exception | error | group-combine, type-system, comparator, invalid-program, dataset-api, flink-core |
| Cannot set a UDF as combinable if it does not implement the | exception | error | group-reduce, combiner, interface-check, dataset-api, flink-core |
| Cannot use custom partitioner for a non-grouped GroupReduce | exception | error | group-reduce, custom-partitioner, keyed-operation, dataset-api, flink-core |
| Cannot use the key partitioner for composite keys (more than | exception | error | group-reduce, custom-partitioner, composite-key, dataset-api, flink-core |
| Input type of GroupReduce must be one of composite types or | exception | error | |
| Type information for left input of type {} is not supported. | exception | error | |
| Type information for right input of type {} is not supported | exception | error | |
| Join Hint must not be null. | exception | error | |
| Type information for input of type {} is not supported. Coul | exception | error | |
| Outer join of type '{}' not supported. | exception | error | |
| Cannot use custom partitioner for a non-grouped GroupReduce | validation | error | |
| Cannot use the key partitioner for composite keys (more than | validation | error | |
| Cannot use custom partitioner for a non-grouped GroupReduce | validation | error | |
| Cannot use the key partitioner for composite keys (more than | validation | error | |
| Grouping is only possible on composite types. | validation | error | |
| Reduce Hint must not be null. | validation | error | |
| Partition sorting does not support type {} yet. | validation | error | |
| Field ID must not be null. | validation | error | |
| FieldSet to add must not be null. | validation | error | |
| Field ID must not be null. | validation | error | |
| FieldSet to add must not be null. | validation | error | |
| User-defined object {} ({}) contains non-serializable field | validation | error | |
| Could not access the fields of the user defined class while | exception | error | |
| The implementation of AbstractDeserializationSchema is using | exception | error | serialization, generics, type-erasure, type-information |
| Field at index %s must be of type byte[], but was %s | validation | error | serialization, row, type-mismatch, kafka |
| Cannot register null class or serializer. | validation | error | serialization, kryo, null-check, configuration |
| Cannot register null type class. | validation | error | serialization, pojo, null-check, configuration |
| Could not load class for serialization config | validation | error | serialization, configuration, classpath, class-loading |
| Could not configure serializers from %s. | validation | error | serialization, configuration, parsing, error-wrapping |
| Duplicated serializer for the same class. | validation | error | serialization, configuration, duplicate, parsing |
| Serializer type not specified for {} | validation | error | serialization, configuration, parsing, missing-field |
| Unsupported serializer type %s for %s | validation | error | serialization, configuration, parsing, validation |
| Class is not a TypeInfoFactory. | validation | error | serialization, type-information, typeinfo-factory, validation |
| A TypeInfoFactory for type '{}' is already registered. | validation | error | serialization, type-information, duplicate, configuration |
| Unable to deserialize message | exception | error | serialization, deserialization, io, schema-mismatch |
| Unable to serialize record | exception | error | serialization, io, type-mismatch, schema |
| Unexpected serializer type. | exception | error | state, serialization, map-state, serializer |
| ReduceFunction of ReducingState can not be a RichFunction. | exception | error | state, reducing-state, rich-function, validation |
| Could not create the type information for '{}'. The most com | exception | error | state-descriptor, type-information, type-erasure, generics, type-extractor |
| Serializer not yet initialized. | exception | error | state-descriptor, serializer, lazy-initialization, default-value |
| Queryable state name already set | exception | error | state-descriptor, queryable-state, deprecated, duplicate-call |
| Unable to serialize default value of type {}. | exception | error | state-descriptor, serialization, default-value, type-serializer |
| Unable to deserialize default value. | exception | error | state-descriptor, deserialization, checkpoint-restore, type-serializer, version-skew |
| Serializer not yet initialized. | exception | error | state-descriptor-v2, map-state, serializer, lazy-initialization |
| Serializer not yet initialized. | exception | error | state-descriptor-v2, serializer, lazy-initialization |
| Could not create the type information for '{}'. The most com | exception | error | state-descriptor-v2, type-information, type-erasure, generics, type-extractor |
| The given class is no array. | exception | error | type-information, array-type, validation, type-extractor |
| The type {} cannot be used as a key. | exception | error | type-information, comparator, key-type, keyby |
| Could not initialize basic comparator {} | exception | error | type-information, comparator, reflection, basic-type |
| Could not initialize comparator {} | exception | error | type-information, comparator, reflection, java-time |
| The Nothing type cannot have a serializer. | exception | error | type-information, nothing-type, sentinel, serializer |
| The given class is no array. | exception | error | type-information, primitive-array, validation, type-extractor |
| Could not initialize primitive {} array comparator. | exception | error | type-information, comparator, reflection, primitive-array |
| Could not initialize comparator {} | exception | error | type-information, comparator, reflection, sql-time |
| The TypeHint is using a generic variable.This is not support | exception | error | type-information, type-hint, generics, type-erasure |
| Cannot extract TypeInformation from Class alone, because gen | exception | error | type-information, type-hint, generics, type-erasure |
| Tuple type expected but was: {} | exception | error | type-information, tuple, pojo, type-extractor, validation |
| POJO type expected but was: {} | exception | error | type-system, pojo, type-extraction, invalid-types-exception |
| Field '{}' could not be accessed. | exception | error | type-system, pojo, reflection, invalid-types-exception |
| Invalid element type for a primitive array. | exception | error | type-system, array, type-info, illegal-argument |
| Could not add a comparator for the logicalkey field index {} | exception | error | type-system, composite-type, comparator, key-selector, illegal-argument |
| A flattened field can not be a composite type | exception | error | type-system, composite-type, internal-invariant, field-selector |
| Corrupt data, magic number mismatch. Expected %8x, found %8x | exception | critical | serialization, checkpoint, savepoint, data-corruption, state, io |
| Undefined compatibility type. | exception | error | serialization, state, schema-compatibility, internal-invariant, custom-serializer |
| unrecognized compatibility type. | exception | error | serialization, state, schema-compatibility, internal-invariant, version-mismatch |
| Number of key fields and comparators differ. | exception | error | comparator, join, co-group, key-selector, illegal-argument |
| Corrupt data, magic number mismatch. Expected %8x, found %8x | exception | critical | serialization, checkpoint, savepoint, data-corruption, state, io |
| Unrecognized version: {} | exception | critical | serialization, checkpoint, savepoint, version-mismatch, state, io |
| Unrecognized version: {} | exception | critical | serialization, checkpoint, savepoint, version-mismatch, state, io |
| Workaround hack. | exception | error | comparator, internal-api, unsupported-operation |
| Unrecognized version for TypeSerializerSnapshot format: {} | exception | critical | serialization, checkpoint, savepoint, version-mismatch, state, io |
| This object is a dummy TypeSerializer. | exception | critical | serialization, state, checkpoint, savepoint, classpath, class-not-found, unsupported-operation |
| Could not create a restore serializer for enum {}. Probably | exception | critical | serialization, state-restore, enum, schema-evolution |
| Exactly one of LocalDate and LocalTime is null. | exception | error | serialization, datetime, corrupt-data |
| Unsupported variant type: {} | exception | error | serialization, variant, internal-api |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, primitive-array |
| The record must not be null. | exception | error | serialization, null-check, string-array |
| This source reader does not support pausing or resuming spli | exception | warning | source, watermark-alignment, source-api |
| TypeInformation cannot be filled in for the type after it ha | exception | error | type-information, type-erasure, datastream-api |
| The return type of function '{functionName}' could not be de | exception | error | type-information, type-erasure, datastream-api |
| The transformation does not support async state, or you are | exception | error | async-state, keyed-state, transformation, streaming |
| The implementation of the {functionType} is not serializable | exception | error | serialization, closure-cleaner, inner-class, user-function |
| Object {obj} is not serializable | exception | error | serialization, closure-cleaner, user-function |
| Could not instantiate org.apache.flink.formats.avro.utils.Av | exception | error | avro, dependency, classpath, serialization |
| Could not load class 'org.apache.flink.formats.avro.utils.Av | exception | error | avro, missing-dependency, serializer, type-system |
| Could not load the AvroSerializer class. You may be missing | exception | error | avro, missing-dependency, serializer, state |
| Could not load the AvroTypeInfo class. You may be missing th | exception | error | avro, missing-dependency, type-info, type-system |
| Type extraction is not possible on Either type as it does no | exception | error | type-extraction, either, generics, type-info |
| Type extraction is not possible on Either type as it does no | exception | error | type-extraction, either, generics, type-info |
| EnumTypeInfo can only be used for subclasses of java.lang.En | exception | error | type-info, enum, validation |
| Generic types have been disabled in the ExecutionConfig and | exception | error | type-info, generic-type, kryo, execution-config |
| Types that do not implement java.lang.Comparable cannot be u | exception | error | key-type, comparator, generic-type, keyed-stream |
| The missing type information cannot be used as a type inform | exception | error | type-extraction, missing-type-info, type-info |
| Invalid POJO field reference "{}". | exception | error | pojo, field-reference, type-system, keyby, flink-core |
| Unable to find field "{}" in type {}. | exception | error | pojo, field-reference, type-system, keyby, flink-core |
| Nested field expression "{}" not possible on atomic type {}. | exception | error | pojo, nested-field, atomic-type, type-system, flink-core |
| Wildcard expressions are not allowed here. | exception | error | pojo, wildcard, gettypeat, type-system, flink-core |
| Invalid format of POJO field expression "{}". | exception | error | pojo, field-reference, gettypeat, type-system, flink-core |
| Invalid tuple field reference "{}". | exception | error | row, field-reference, type-system, flink-core |
| Nested field expression "{}" not possible on atomic type {}. | exception | error | row, nested-field, atomic-type, type-system, flink-core |
| Wildcard expressions are not allowed here. | exception | error | row, wildcard, gettypeat, type-system, flink-core |
| Invalid format of Row field expression "{}". | exception | error | row, field-reference, gettypeat, type-system, flink-core |
| Type at position {} is null. | exception | error | tuple, null-check, type-system, factory-method, flink-core |
| Type at position {} is not a basic type. | exception | error | tuple, basic-type, type-system, factory-method, flink-core |
| Type at position {} is not a basic or value type. | exception | error | tuple, value-type, basic-type, type-system, factory-method, flink-core |
| Invalid tuple field reference "{}". | exception | error | tuple, field-reference, type-system, keyby, flink-core |
| Tuple field expression "{}" out of bounds of {}. | exception | error | tuple, out-of-bounds, field-reference, type-system, flink-core |
| Nested field expression "{}" not possible on atomic type {}. | exception | error | tuple, nested-field, atomic-type, type-system, flink-core |
| Wildcard expressions are not allowed here. | exception | error | type-extraction, tuple, field-expression, wildcard |
| Invalid format of tuple field expression "{}". | exception | error | type-extraction, tuple, field-expression, invalid-format |
| No lambda method found. | exception | error | type-extraction, lambda, reflection, classloader |
| Could not extract lambda method out of function: {} - {} | exception | error | type-extraction, lambda, reflection, classloader, security |
| Cannot extract the type argument with index {} because the t | exception | error | type-extraction, generics, type-argument, lambda |
| The given type {} is not a parameterized type. | exception | error | type-extraction, generics, raw-type, type-argument |
| Given class: {}is not a FunctionalInterface. | exception | error | type-extraction, functional-interface, lambda, reflection |
| Given class: {} is not a FunctionalInterface. It has more th | exception | error | type-extraction, functional-interface, lambda, sam |
| Given class: {} is not a FunctionalInterface. It does not ha | exception | error | type-extraction, functional-interface, lambda, sam |
| Cannot convert type to class | exception | error | type-extraction, generics, type-variable, reflection |
| The generic type parameters of '{}' are missing. In many cas | exception | error | type-extraction, lambda, generics, type-erasure, common |
| Class is not a TypeInfoFactory. | exception | error | type-extraction, typeinfo-factory, registration, programming-error |
| A TypeInfoFactory for type '{}' is already registered. | exception | error | type-extraction, typeinfo-factory, registration, duplicate |
| Internal error occurred. | exception | error | type-extraction, lambda, unary-operator, internal-error |
| Could not extract type information. | exception | error | type-extraction, create-typeinfo, unsupported-type, typeinfo-factory |
| Usage of class Tuple as a type is not allowed. Use a concret | exception | error | type-extraction, tuple, raw-type, type-erasure |
| Tuple needs to be parameterized by using generics. | exception | error | type-extraction, tuple, generics, reflection |
| Type of TypeVariable '{}' in '{}' could not be determined. T | exception | error | type-extraction, type-erasure, generics, type-variable |
| Type Information could not be created. | exception | error | type-extraction, unsupported-type, reflection, catch-all |
| TypeInformation '{}' does not supply a mapping of TypeVariab | exception | error | type-extraction, typeinfo-factory, generics, custom-type |
| TypeInfoFactory returned invalid TypeInformation 'null' | exception | error | type-extraction, typeinfo-factory, custom-type, null-return |
| The types of the interface {} could not be inferred. Support | exception | error | type-extraction, interface, raw-type, generics, reflection |
| Input mismatch: {} | exception | error | type-validation, input-mismatch, type-extraction, reflection |
| Unknown Error. Type is null. | exception | error | type-extraction, internal-error, null-type, validation |
| Unknown Error. TypeInformation is null. | exception | error | type-extraction, internal-error, null-typeinfo, validation |
| Basic type expected. | exception | error | type-validation, basic-type, type-mismatch, reflection |
| Basic type '{}' expected but was '{}'. | exception | error | type-validation, basic-type, type-mismatch, reflection |
| SQL time type expected. | exception | error | type-validation, sql-time, type-mismatch, reflection, temporal |
| SQL time type '{}' expected but was '{}'. | exception | error | type-validation, sql-time, type-mismatch, reflection, temporal |
| Tuple type expected. | exception | error | type-validation, tuple, type-mismatch, reflection |
| Concrete subclass of Tuple expected. | exception | error | type-validation, tuple, raw-type, type-mismatch, reflection |
| Parameterized Tuple type expected. | exception | error | type-validation, tuple, raw-type, generics, reflection |
| Tuple arity '{}' expected but was '{}'. | exception | error | type-validation, tuple, arity-mismatch, type-mismatch, reflection |
| Array type expected. | exception | error | type-validation, primitive-array, type-mismatch, reflection, array |
| Primitive component expected. | exception | error | type-validation, primitive-array, type-mismatch, boxing, reflection, array |
| Object array type expected. | exception | error | type-extraction, object-array, typeinfo, udf |
| Value type expected. | exception | error | type-extraction, value-type, typeinfo, udf |
| POJO type '{}' expected but was '{}'. | validation | error | type-extraction, pojo, type-mismatch, typeinfo |
| Enum type expected. | validation | error | type-extraction, enum, typeinfo, udf |
| Enum type '{}' expected but was '{}'. | validation | error | type-extraction, enum, type-mismatch, typeinfo |
| Generic type '{}' or a subclass of it expected but was '{}'. | validation | error | type-extraction, generic-type, type-mismatch, typeinfo |
| TypeInfo annotation does not specify a valid TypeInfoFactory | validation | error | type-extraction, typeinfo-annotation, typeinfofactory, configuration |
| Type information extraction for tuples (except Tuple0) canno | validation | error | type-extraction, tuple, generic-types, typeinfo |
| The field {} is already contained in the hierarchy of the {} | validation | error | pojo, field-shadowing, class-hierarchy, type-extraction |
| Automatic type extraction is not possible on candidates with | validation | error | type-extraction, tuple, null-values, runtime-inference |
| Could not load the TypeInformation for the class '{}'. You m | exception | critical | hadoop, writable, missing-dependency, classpath |
| Incompatible versions of the Hadoop Compatibility classes fo | exception | critical | hadoop, writable, version-mismatch, classpath |
| Cannot create Hadoop WritableTypeInfo. | exception | critical | hadoop, writable, reflection, instantiation |
| org.apache.hadoop.io.Writable type expected. | validation | error | hadoop, writable, type-mismatch, typeinfo |
| Writable type '{}' expected but was '{}'. | validation | error | hadoop, writable, type-mismatch, typeinfo |
| The type {} is not Comparable. | exception | error | value-type, comparator, comparable, key-type |
| The given class is no subclass of {} | validation | error | value-type, type-validation, typeinfo, subclass-check |
| Could not instantiate record | exception | error | serialization, records, reflection, kryo |
| Could not find record canonical constructor | exception | error | serialization, records, reflection, classloader |
| Could not copy object by serializing/deserializing it. | exception | error | kryo, serialization, copy, state |
| NoFetchingInput cannot prefetch data. | exception | error | kryo, serialization, streaming-input, unsupported-operation |
| Buffer too small: capacity: {}, required: {} | exception | error | kryo, serialization, buffer, stream-corruption |
| Buffer underflow. | exception | error | kryo, serialization, eof, stream-corruption |
| bytes cannot be null. | validation | error | kryo, serialization, null-argument, programmer-error |
| No more bytes left. | exception | error | kryo, serialization, eof, truncated-data |
| Comparator does not support null-aware serialized comparison | exception | error | comparator, null-handling, serialized-comparison, unsupported-operation |
| Record serialization with leading normalized keys not suppor | exception | error | comparator, null-handling, normalized-key, unsupported-operation |
| Record deserialization with leading normalized keys not supp | exception | error | comparator, null-handling, normalized-key, unsupported-operation |
| Comparator {} specifies an invalid length for the normalized | exception | error | comparator, pojo, normalized-key, sort |
| Cannot copy serializer | exception | error | pojo, comparator, java-serialization, classloader |
| Unable to access field {} on object {} | exception | error | pojo, comparator, null-record, keyed-stream |
| A NullPointerException occurred while accessing a key field | exception | error | pojo, comparator, null-key, hashing |
| {} | exception | error | pojo, comparator, null-key, sorting |
| Cannot instantiate class. | exception | error | pojo, serialization, reflection, type-system, state-restore |
| Cannot initialize fields. | exception | error | pojo, serialization, reflection, field-access, java-modules |
| {} | exception | error | row, comparator, key-position, arity-mismatch, dataset-api |
| Record serialization with leading normalized keys not suppor | exception | error | row, comparator, unsupported-operation, normalized-key, dataset-api |
| Record deserialization with leading normalized keys not supp | exception | error | row, comparator, unsupported-operation, normalized-key, dataset-api |
| Comparator {} specifies an invalid length for the normalized | exception | error | row, comparator, normalized-key, comparator-contract, custom-comparator |
| Row arity of from ({}) does not match this serializer's fiel | exception | error | row, serializer, arity-mismatch, schema, position-based |
| Serializer does not support named field positions. | exception | error | row, serializer, named-fields, schema, position-based |
| Row arity of reuse ({}) or from ({}) is incompatible with th | exception | error | row, serializer, arity-mismatch, reuse, schema |
| Row arity of record ({}) does not match this serializer's fi | exception | error | row, serializer, arity-mismatch, serialization, schema |
| Row arity of reuse ({}) does not match this serializer's fie | exception | error | row, serializer, arity-mismatch, deserialization, reuse |
| Unknown field name '%s' for mapping to a row position. Avail | exception | error | row, serializer, named-fields, schema-mismatch, field-name |
| Could not serialize comparator into the configuration. | exception | error | serialization, comparator, java-serialization, job-submission |
| Could not serialize serializer into the configuration. | exception | error | serialization, deserialization, classloader, version-mismatch |
| ComparatorFactory has not been initialized from configuratio | exception | error | lifecycle, comparator, initialization, misuse |
| Could not serialize serializer into the configuration. | exception | error | serialization, type-serializer, java-serialization, job-submission |
| Could not load deserializer from the configuration. | exception | error | serialization, deserialization, version-mismatch, classloader |
| SerializerFactory has not been initialized from configuratio | exception | error | lifecycle, type-serializer, initialization, misuse |
| Tuple0 cannot take any data, as it has zero fields. | exception | error | tuple, arity-mismatch, misuse, typeutils |
| Field {fieldNumber} is accessed for a key, but out of bounds | exception | error | tuple, key-position, out-of-bounds, comparator, partitioning |
| Field {fieldNumber} is null, but expected to hold a key. | exception | error | tuple, null-key, normalized-key, sorting, data-quality |
| Comparator {className} specifies an invalid length for the n | exception | error | comparator, normalized-key, custom-comparator, contract-violation |
| Field {fieldNumber} is null, but expected to hold a key. | exception | error | tuple, null-key, comparator, reference-compare, data-quality |
| Field {fieldNumber} is accessed for a key, but out of bounds | exception | error | tuple, key-position, out-of-bounds, comparator, reference-compare |
| Cannot instantiate tuple. | exception | error | tuple, instantiation, reflection, typeutils |
| Field {fieldIdx} is null, but expected to hold a value. | exception | error | tuple, null-field, serialization, data-quality, typeutils |
| Error during Java serialization. | exception | error | serialization, kryo, java-serialization, flink-core |
| Error during Java deserialization. | exception | error | serialization, kryo, deserialization, state-migration, flink-core |
| The Kryo Output still contains data from a previous serializ | exception | error | serialization, kryo, buffer-overflow, flink-core |
| Could not clone serializer instance of class {className} | exception | error | kryo, serialization, custom-serializer, flink-core |
| Concurrent access to KryoSerializer. Thread 1: {threadName1} | exception | error | thread-safety, kryo, concurrency, flink-core |
| Unrecognized Kryo registration serializer definition type: { | exception | error | kryo, snapshot, internal-invariant, flink-core |
| Unrecognized Kryo registration serializer definition type: { | exception | critical | kryo, checkpoint-restore, corruption, flink-core |
| Could not find required Avro dependency. | exception | error | kryo, avro, missing-dependency, flink-core |
| Configuration cannot evaluate value %s as a byte[] value | validation | error | configuration, type-mismatch, legacy-api, flink-core |
| Value for config option %s must be one of %s (was %s) | validation | error | configuration, enum, validation, flink-core |
| Could not parse value for key '%s'. | validation | error | configuration, parse-error, sensitive-keys, security, flink-core |
| Could not parse value '%s' for key '%s'. | validation | error | configuration, parse-error, yaml, flink-core |
| Unrecognized type: %s. This method is deprecated and might n | exception | error | configuration, deserialization, corruption, legacy-api, flink-core |
| Unrecognized type. This method is deprecated and might not w | exception | error | configuration, serialization, legacy-api, type-mismatch, flink-core |
| Given configuration directory is null, cannot load configura | validation | error | configuration, null-argument, startup, flink-core |
| The given configuration directory name '{}' ({}) does not de | validation | error | configuration, path, startup, environment, flink-core |
| The Flink config file '{}' ({}) does not exist. | validation | error | configuration, missing-file, startup, migration, flink-core |
| Error parsing YAML configuration. | exception | error | configuration, io, permissions, startup, flink-core |
| Unsupported type: {} | validation | error | configuration, type-conversion, configoption |
| Map item is not a key-value pair (missing ':'?) | validation | error | configuration, map-parsing, legacy |
| Configuration value %s overflows/underflows the integer type | validation | error | configuration, type-conversion, numeric-overflow |
| Unrecognized option for boolean: %s. Expected either true or | validation | error | configuration, type-conversion, boolean |
| Configuration value %s overflows/underflows the float type. | validation | error | configuration, type-conversion, numeric-overflow |
| Given configuration directory is null, cannot load configura | validation | error | configuration, startup, null-check |
| The given configuration directory name '{}' ({}) does not de | validation | critical | configuration, startup, filesystem |
| The Flink config file '{}' ({}) does not exist. | validation | critical | configuration, startup, filesystem, yaml |
| Error parsing YAML configuration. | exception | critical | configuration, yaml, startup, parsing |
| %s is an unknown value of RestartStrategyType. | validation | error | configuration, restart-strategy, enum |
| Could not split string. Illegal quoting at position: {} | validation | error | configuration, structured-parsing, quoting |
| Could not split string. Quoting was not closed properly. | validation | error | configuration, structured-parsing, quoting |
| The configuration is unmodifiable; its contents cannot be ch | exception | warning | configuration, immutability, unsupported-operation |
| Class '%s' not found. Perhaps you forgot to add the module ' | exception | critical | classloading, classpath, module, deployment |
| Cannot retrieve platform classloader on Java 9+ | exception | critical | classloading, jvm, reflection, startup |
| Multiple compatible client factories found for: {}. | exception | error | execution, deployment, service-loader, configuration |
| No ExecutorFactory found to execute the application. | exception | critical | execution, deployment, service-loader, classpath |
| Job was submitted in detached mode. Results of job execution | exception | error | execution, detached-mode, runtime |
| Job was submitted in detached mode. Results of job execution | exception | error | execution, detached-mode, accumulators, eager-functions |
| Can not create a Path from an empty string | validation | error | path, validation, configuration, filesystem |
| Error reconstructing URI | exception | error | serialization, deserialization, uri, state, corruption |
| Cannot sync state to system like S3. Use persist() to create | exception | error | filesystem, s3, object-store, sync, recoverable-writer |
| Stream closed. | exception | error | filesystem, stream, resource-lifecycle, use-after-close |
| Stream closed. | exception | error | filesystem, reference-counting, resource-lifecycle, use-after-close |
| Stream closed. | exception | error | filesystem, stream, reference-counting, use-after-close |
| tempDirectories contains null entries | validation | error | filesystem, configuration, validation, temp-dir |
| File status does not belong to the LocalFileSystem: {} | exception | error | filesystem, local-fs, type-mismatch, input-format |
| File {} does not exist or the user running Flink ('{}') has | exception | error | filesystem, local-fs, permissions, file-not-found, configuration |
| Directory {} does not exist or an I/O error occurred | exception | error | filesystem, local-fs, delete, permissions, race-condition |
| Directory {} is not empty | exception | error | filesystem, local-fs, delete, configuration |
| {} | exception | error | filesystem, local-fs, mkdir, file-conflict, configuration |
| File already exists: {} | exception | error | filesystem, local-fs, create, overwrite, configuration |
| Mkdirs failed to create {} | exception | error | filesystem, local-fs, mkdir, permissions, create |
| File Not Found: {} | exception | error | filesystem, local-fs, recoverable-writer, recovery, file-not-found |
| Missing data in tmp file: {} | exception | error | filesystem, local-fs, recoverable-writer, recovery, data-loss |
| Cannot clean commit: File has trailing junk data. | exception | error | filesystem, local-fs, recoverable-writer, commit, race-condition |
| Committing file failed, could not rename {} -> {} | exception | error | filesystem, local-fs, recoverable-writer, commit, rename, cross-device |
| Committing file failed. Target file already exists: {} | exception | error | filesystem, local-fs, recoverable-writer, commit, duplicate |
| Unrecognized version or corrupt state: {} | exception | error | serialization, local-filesystem, checkpoint-restore, version-mismatch |
| Corrupt data: Unexpected magic number. | exception | error | serialization, local-filesystem, data-corruption, magic-number |
| Failed to create the parent directory: {} | exception | error | local-filesystem, filesystem-io, permissions, sink |
| LocalFileSystem cannot recover recoverable for other file sy | exception | error | local-filesystem, type-mismatch, sink, recovery |
| PostVersionedIOReadableWritable cannot read from a DataInput | exception | error | serialization, versioned-io, api-misuse, unsupported-operation |
| Corrupt data, conflicting lengths. Length fields: {}, data: | exception | error | serialization, data-corruption, framing, versioned-io |
| Could not duplicate SimpleVersionedSerializer. | exception | error | serialization, type-serializer, classloader, java-serialization |
| Could not copy element. | exception | error | serialization, type-serializer, copy, null-safety |
| SimpleVersionedSerializerWrapper is not meant to be used as | exception | error | type-serializer, state-backend, unsupported-operation, api-misuse |
| Incompatible version: found {}, compatible versions are {} | exception | error | serialization, version-mismatch, checkpoint-restore, versioned-io |
| There is no enough data left in the DataInputView. | exception | error | memory, paged-io, data-corruption, eof |
| malformed input: partial character at end | exception | error | memory, paged-io, utf-8, data-corruption |
| malformed input around byte {} | exception | error | memory, paged-io, utf-8, data-corruption |
| Initial Segment may not be null | exception | error | memory, paged-io, null-pointer, memory-management |
| encoded string too long: {} memory | exception | error | memory, paged-io, utf-8, size-limit |
| The given buffer is neither an array-backed heap ByteBuffer, | exception | error | memory, deserialization, bytebuffer, api-misuse |
| Invalid bounds. | exception | error | serialization, bounds-check, validation, deserialization |
| Length may not be negative. | exception | error | serialization, bounds-check, deserialization, validation |
| malformed input: partial character at end | exception | error | serialization, modified-utf-8, deserialization, corruption, string |
| malformed input around byte {count} | exception | error | serialization, modified-utf-8, deserialization, corruption, string |
| malformed input around byte {count-1} | exception | error | serialization, modified-utf-8, deserialization, corruption, string |
| Could not skip {numBytes} bytes. | exception | error | serialization, deserialization, eof, bounds-check |
| Offset cannot be negative. | exception | error | serialization, bounds-check, deserialization, validation |
| Length cannot be negative. | exception | error | serialization, bounds-check, deserialization, validation |
| Byte array does not provide enough space to store requested | exception | error | serialization, bounds-check, deserialization, validation |
| Could not skip {numBytes} bytes. | exception | error | serialization, stream, eof, deserialization |
| offset: %d, length: %d, size: %d | exception | error | serialization, memory-segment, bounds-check, validation |
| Encoded string is too long: {utflen} | exception | error | serialization, utf-8, string, size-limit |
| Encoded string reached maximum length: {utflen} | exception | critical | serialization, utf-8, string, size-limit, memory |
| Serialization failed because the record length would exceed | exception | critical | serialization, size-limit, memory, array-overflow |
| Failed to serialize element. Serialized size (> {newLen} byt | exception | critical | serialization, memory, out-of-memory, jvm-config |
| Could not skip {numBytes} bytes. | exception | error | serialization, bounds-check, buffer-overflow |
| Could not write {numBytes} bytes. Buffer overflow. | exception | error | serialization, memory, flink-core, buffer-overflow |
| MemorySegment can be freed only once! | exception | error | memory, lifecycle, flink-core, double-free |
| Memory segment does not represent heap memory | exception | error | memory, off-heap, flink-core, api-misuse |
| Memory segment does not represent off-heap buffer | exception | error | memory, heap, flink-core, api-misuse |
| Memory segment does not represent off heap memory | exception | error | memory, unsafe, flink-core, api-misuse |
| Wrap is not supported by this segment. This usually indicate | exception | error | memory, bytebuffer, flink-core, ownership |
| segment has been freed | exception | error | memory, lifecycle, flink-core, use-after-free |
| offset=%d, numBytes=%d, address=%d | exception | error | memory, unsafe, flink-core, bounds-check |
| this memory segment has been freed. | exception | error | memory, lifecycle, flink-core, use-after-free |
| other memory segment has been freed. | exception | error | memory, lifecycle, flink-core, use-after-free |
| offset1=%d, offset2=%d, len=%d, bufferSize=%d, address1=%d, | exception | error | memory, bounds-check, flink-core, sorting |
| Segment size must be a power of 2! | validation | error | memory, validation, flink-core, configuration |
| Plugins root directory [%s] does not exist! | exception | error | plugins, configuration, flink-core, filesystem |
| Cannot find any jar files for plugin in directory [%s]. Plea | exception | error | plugins, configuration, flink-core, filesystem |
| Exception when trying to initialize plugin system. | exception | critical | plugins, startup, flink-core, configuration |
| Could not register security manager due to no permission to | validation | error | security, configuration, flink-core, java-17, startup |
| Could not un-export our RMI registry | exception | warning | jmx, rmi, shutdown, flink-core |
| Cannot retrieve Right value on a Left | exception | error | types, either, flink-core, api-misuse |
| Cannot retrieve Left value on a Right | exception | error | types, either, flink-core, api-misuse |
| Object is no primitive Java type. | validation | error | |
| %s for range [0..%s] | exception | error | |
| The target object may not be null | validation | error | |
| Field %s is null, but expected to hold a key. | exception | error | |
| Error reading field %s as %s | exception | error | |
| Error creating field union of record data: %s | exception | error | |
| Error in data type serialization: %s | exception | error | |
| Error serializing Record header: %s | exception | error | |
| Length may not be negative. | exception | error | |
| malformed input: partial character at end | exception | error | |
| malformed input around byte {} | exception | error | |
| Could not skip {}. | exception | error | |
| Byte array b cannot be null. | exception | error | |
| Offset cannot be negative. | exception | error | |
| Length cannot be negative. | exception | error | |
| Byte array does not provide enough space to store requested | exception | error | flink, serialization, record, index-out-of-bounds, argument-validation |
| Encoded string is too long: {} | exception | error | flink, serialization, record, utf, size-limit |
| Could not skip {} bytes. | exception | error | flink, serialization, record, eof, bounds-check |
| Could not write {} bytes since the buffer is full. | exception | error | flink, serialization, record, buffer-full, capacity |
| Accessing a field by position is not supported in name-based | exception | error | flink, row, api-misuse, field-access, illegal-argument |
| Unknown field name '%s' for mapping to a position. | exception | error | flink, row, field-name, illegal-argument, schema-mismatch |
| Accessing a field by name is not supported in position-based | exception | error | flink, row, api-misuse, field-access, illegal-argument |
| Unknown field name '%s' for mapping to a row position. Avail | exception | error | flink, row, field-name, illegal-argument, schema-mismatch |
| Unsupported byte value '{}' for row kind. | exception | error | flink, row-kind, deserialization, unsupported-operation, changelog |
| No value present | exception | error | flink, optional, no-such-element, null-handling |
| Length must be between 0 and the current length. | exception | error | flink, string-value, illegal-argument, api-misuse |
| offset: {} len: {} value.len: {} | exception | error | flink, string-value, index-out-of-bounds, bounds-check |
| Bytes must not be null | exception | error | flink, string-value, null-pointer, ascii |
| Cannot find empty string. | exception | error | flink, string-value, illegal-argument, search |
| CharSequence is too long. | exception | error | serialization, stringvalue, overflow, flink-core |
| Failed to deserialize bitmap from bytes. | exception | error | bitmap, roaringbitmap, deserialization, data-corruption, flink-core |
| Unsupported bitmap type: %s. | exception | error | bitmap, type-check, illegalargument, flink-core |
| Invalid input: Empty string | exception | error | parser, bigdecimal, empty-field, csv, flink-core |
| There is leading or trailing whitespace in the numeric field | exception | error | parser, bigdecimal, whitespace, csv, flink-core |
| There is leading or trailing whitespace in the numeric field | exception | error | parser, bigint, whitespace, csv, flink-core |
| Empty field. | exception | error | parser, byte, empty-field, csv, flink-core |
| Orphaned minus sign. | exception | error | parser, byte, malformed-number, csv, flink-core |
| Invalid character. | exception | error | parser, byte, invalid-character, csv, flink-core |
| Value overflow/underflow | exception | error | parser, byte, overflow, csv, flink-core |
| There is leading or trailing whitespace in the numeric field | exception | error | parser, double, whitespace, csv, flink-core |
| Invalid input: Empty string | exception | error | parser, fieldparser, empty-field, validation, flink-core |
| There is leading or trailing whitespace in the numeric field | exception | error | parser, float, whitespace, csv, flink-core |
| Empty field. | exception | error | parser, int, empty-field, csv, flink-core |
| Orphaned minus sign. | exception | error | parser, int, malformed-number, csv, flink-core |
| Invalid character. | exception | error | parser, int, invalid-character, csv, flink-core |
| Value overflow/underflow | exception | error | parser, int, overflow, csv, flink-core |
| Empty field. | exception | error | parser, long, empty-field, csv, flink-core |
| Orphaned minus sign. | exception | error | parser, long, malformed-number, csv, flink-core |
| Invalid character. | exception | error | parser, long, invalid-character, csv, flink-core |
| value overflow | exception | error | parsing, csv, long, overflow, flink-core |
| Empty field. | exception | error | parsing, csv, short, empty-field, flink-core |
| Orphaned minus sign. | exception | error | parsing, csv, short, data-quality, flink-core |
| Invalid character. | exception | error | parsing, csv, short, invalid-input, flink-core |
| Value overflow/underflow | exception | error | parsing, csv, short, overflow, flink-core |
| Expecting a primitive variant but got %s | exception | error | variant, type-mismatch, flink-core, semi-structured |
| Id must not be null. | validation | error | flink-core, validation, null-safety, id |
| No data for required key '{key}' | exception | error | flink-core, configuration, parameter-tool, startup |
| Could not close resource. | exception | error | flink-core, lifecycle, async, shutdown, resource-management |
| Mkdirs failed to create {targetDir} | exception | error | flink-core, compression, filesystem, permissions, tar |
| Interrupted when untarring file {inFilePath} | exception | error | flink-core, compression, concurrency, interruption, tar |
| Error untarring file {inFilePath}. Tar process exited with e | exception | error | flink-core, compression, tar, corrupt-archive, process |
| expanding {entry.getName()} would create entry outside of {t | exception | critical | flink-core, compression, security, zip-slip, path-traversal, tar |
| Failed to create directory {outputFile} | exception | error | flink-core, compression, filesystem, tar, windows |
| Mkdirs failed to create tar internal dir {targetDir} | exception | error | flink-core, compression, filesystem, permissions, tar |
| Expand {entry.getName()} would create a file outside of {tar | exception | critical | flink-core, compression, security, zip-slip, path-traversal, zip |
| Create dir: {outputFile.getAbsolutePath()} failed! | exception | error | flink-core, compression, zip, filesystem, permissions |
| Create file: {outputFile.getAbsolutePath()} failed! | exception | error | flink-core, compression, zip, filesystem, idempotency |
| There are no legal characters in the file name | validation | error | flink-core, filesystem, validation, file-lock, sanitization |
| Required array size too large | panic | critical | flink-core, filesystem, memory, large-files, out-of-memory |
| {directory} is not a directory | exception | error | flink-core, filesystem, cleanup, validation |
| Failed to list contents of {directory} | exception | error | flink-core, filesystem, permissions, cleanup, io |
| {directory} | exception | warning | flink-core, filesystem, cleanup, race-condition, concurrency |
| {directory} is not a directory but a regular file | exception | error | flink-core, filesystem, cleanup, validation, configuration |
| operation interrupted | exception | warning | filesystem, windows, interruption, concurrency |
| Illegal escape from target directory | exception | error | security, zip-slip, filesystem, archive |
| The directory %s dose not exist. | validation | error | filesystem, validation, configuration |
| The %s is not a directory. | validation | error | filesystem, validation, configuration |
| Unknown class resolution order: {resolveOrder} | validation | error | classloader, configuration, internal-api |
| Unknown resolve order: {resolveOrder} | validation | error | classloader, configuration, startup |
| Trying to access closed classloader. Please check if you sto | exception | error | classloader, memory-leak, session-cluster, shutdown |
| Unable to write to output stream. | exception | error | io, stream, process-output, printstream |
| Premature EOF from inputStream | exception | error | io, stream, corruption, serialization |
| Premeture EOF from inputStream | exception | error | io, stream, custom-stream, eof |
| conflicting non-public interface class loaders | exception | error | serialization, classloader, proxy, duplicate-classes |
| Could not instantiate class '%s' of type '%s'. Please make s | exception | error | classloader, configuration, classpath, shading |
| The class '{}' is not a subclass of '{}' as is required. | exception | error | reflection, classloader, api-mismatch |
| Could not instantiate type '{}' due to an unspecified except | exception | error | reflection, instantiation, accessibility, jpms |
| Could not instantiate type '{}' Most likely the constructor | exception | error | reflection, instantiation, constructor-exception |
| The class '{}' is not instantiable: {} | exception | error | reflection, instantiation, validation |
| Record to serialize to byte array must not be null. | exception | error | serialization, null-handling, validation |
| Byte array to deserialize from must not be null. | exception | error | serialization, null-handling, validation |
| Unable to clone instance of %s. | exception | error | serialization, cloning, classloader, runtime |
| Could not find class '{}' in classpath. TypeSerializerConfig | exception | critical | checkpointing, restore, upgrade, migration, classloader, serialization |
| The class {} is not a subclass of {} | exception | critical | checkpointing, restore, upgrade, type-hierarchy, serialization |
| JAR file path is invalid '{}' | exception | error | jar, url, classpath, configuration |
| JAR file does not exist '{}' | exception | error | jar, classpath, file-not-found, deployment |
| JAR file can't be read '{}' | exception | error | jar, permissions, filesystem, deployment |
| Error while opening jar file '{}' | exception | error | jar, corruption, zip, classpath, download |
| JAR file path invalid | exception | error | jar, url, validation, classpath |
| Problem with jar file {} | exception | error | jar, classpath, configuration, deployment |
| Missing key '{}' | exception | error | map, optional, configuration, table |
| Missing value for the key '{}' | exception | error | map, optional, configuration, table |
| The 'to' value must not be smaller than the 'from' value. | exception | error | iterator, range, validation, test-data |
| The number of partitions must be at least 1. | exception | error | iterator, parallelism, validation, split |
| Logarithm of zero is undefined. | exception | error | math, logarithm, validation, sizing |
| The given value {} is not a power of two. | exception | error | math, logarithm, power-of-two, configuration, sizing |
| Cannot downcast long value {} to integer. | exception | error | math, overflow, casting, sizing, validation |
| No data for required key '{}' | exception | error | cli, parameters, configuration, usage |
| fqdn is null | validation | error | network, hostname, null-check, configuration |
| hostPort should not be null or empty | validation | error | network, address, validation, configuration |
| The given host:port ('{}') doesn't contain a valid host | validation | error | network, configuration, url-parsing, flink-core |
| The given host:port ('{}') doesn't contain a valid port | validation | error | network, configuration, url-parsing, flink-core |
| The given host:port ('{}') is invalid | validation | error | network, url-parsing, ipv6, flink-core |
| Could not find a free permitted port on the machine. | exception | error | network, ports, concurrency, environment, flink-core |
| The configured hostname is not valid | validation | error | network, configuration, hostname, ipv6, flink-core |
| address is null | validation | error | network, null-safety, flink-core |
| Unrecognized type of InetAddress: {} | validation | error | network, testing, flink-core |
| Address cannot be resolved: {} | validation | error | network, dns, flink-core |
| Invalid port configuration. Port must be between 0and 65535, | validation | error | configuration, ports, validation, flink-core |
| Invalid port configuration. Port must be between 0and 65535, | validation | error | configuration, ports, validation, flink-core |
| Invalid port configuration. Port must be between 0and 65535, | validation | error | configuration, ports, validation, flink-core |
| Invalid port configuration. Port range end must be bigger th | validation | error | configuration, ports, validation, flink-core |
| Remove not supported | exception | error | iterator, ports, api-misuse, flink-core |
| The 'to' value must not be smaller than the 'from' value. | validation | error | iterator, validation, flink-core |
| The number of partitions must be at least 1. | validation | error | iterator, parallelism, validation, flink-core |
| Could not determine TypeInformation for the OutputTag type. | validation | error | side-outputs, type-information, generics, flink-core |
| The input {} contains an empty argument | validation | error | cli, configuration, validation, flink-core |
| Properties file {} does not exist | exception | error | configuration, file-io, classpath, flink-core |
| File {} exists and overwriting is not allowed | exception | error | configuration, file-io, flink-core |
| Invalid port range: "{}" | validation | error | configuration, ports, validation, flink-core |
| Value for configuration key='${key}' is not set correctly. E | exception | error | configuration, properties, parsing, validation |
| Resource guard was already closed. | exception | error | concurrency, lifecycle, resource-management, shutdown |
| negative duration is not supported | exception | error | configuration, duration, parsing, validation |
| text does not start with a number, and is not a valid ISO-86 | exception | error | configuration, duration, parsing, iso-8601 |
| The value '${number}' cannot be represented as an integer nu | exception | error | configuration, duration, parsing, fractional |
| Time interval unit label '${unitLabel}' does not match any o | exception | error | configuration, duration, units, parsing |
| The value '${number}' cannot be represented as Duration (num | exception | error | configuration, duration, overflow, parsing |
| Error parsing arguments '%s' on '%s'. Please prefix keys wit | exception | error | cli, arguments, parsing, validation |
| The input ${args} contains an empty argument | exception | error | cli, arguments, parsing, shell |
| Task has been cancelled. | exception | warning | concurrency, executor, future, cancellation |
| No tasks finished successfully. | exception | error | concurrency, executor, invoke-any, failover |
| Could not finish execution of tasks within time. | exception | error | concurrency, executor, timeout, invoke-any |
| The ExecutorService is shut down already. No Callables can b | exception | error | concurrency, executor, shutdown, lifecycle |
| The cpu cores should be positive. | validation | error | configuration, resource-spec, validation, builder |
| The task heap memory should be positive. | validation | error | configuration, memory, resource-spec, validation |
| The cpu cores and task heap memory are required when specify | validation | error | configuration, resource-spec, builder, validation |
| The tuple arity must be in [0, 25]. | validation | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | |
| {pos} | exception | error | tuple, index-out-of-bounds, flink-core-api, validation |
| {pos} | exception | error | tuple, index-out-of-bounds, flink-core-api, validation |
| {pos} | exception | error | tuple, index-out-of-bounds, flink-core-api, validation |
| {pos} | exception | error | tuple, index-out-of-bounds, flink-core-api, validation |
| bytes must be >= 0 | exception | error | memory, configuration, validation, flink-core-api |
| multiplier must be >= 0 | exception | error | memory, validation, arithmetic, flink-core-api |
| long overflow | exception | error | memory, overflow, arithmetic, flink-core-api |
| divisor must be != 0 | exception | error | memory, validation, arithmetic, flink-core-api |
| argument is an empty- or whitespace-only string | exception | error | memory, configuration, parsing, validation, flink-core-api |
| text does not start with a number | exception | error | memory, parsing, number-format, configuration, flink-core-api |
| The value '{number}' cannot be re represented as 64bit numbe | exception | error | memory, parsing, overflow, configuration, flink-core-api |
| The value '{text}' cannot be re represented as 64bit number | exception | error | memory, parsing, overflow, configuration, flink-core-api |
| Memory size unit '{unit}' does not match any of the recogniz | exception | error | memory, parsing, configuration, units, flink-core-api |
| Can not register process function transformation translator. | exception | critical | datastream-v2, classpath, linkage, startup, version-mismatch |
| Unsupported type of source, you could use DataStreamV2Source | exception | error | datastream-v2, source, api-migration, flip-27 |
| Collection must not be empty | exception | error | datastream-v2, type-extraction, validation |
| Collection must not contain null elements | exception | error | datastream-v2, type-extraction, null-safety |
| Could not create TypeInformation for type {type}; please spe | exception | error | datastream-v2, type-extraction, generics |
| Failed to execute job '{jobName}'. | exception | critical | datastream-v2, job-submission, executor |
| Window {window} is not in in-flight window set. | exception | error | flink, datastream-v2, windowing, session-windows, merging-window-set, state-consistency |
| The window uses a merging assigner, but the window state is | exception | critical | flink, datastream-v2, windowing, session-windows, state-backend, operator-init |
| The end timestamp of an event-time window cannot become earl | exception | error | flink, datastream-v2, windowing, session-windows, event-time, watermark, late-data |
| The end timestamp of a processing-time window cannot become | exception | error | flink, datastream-v2, windowing, session-windows, processing-time, backpressure |
| Window {window} is not in in-flight window set. | exception | error | flink, datastream-v2, windowing, session-windows, merging-window-set, state-consistency |
| The window uses a merging assigner, but the window state is | exception | critical | flink, datastream-v2, windowing, session-windows, two-input, state-backend, operator-init |
| The end timestamp of an event-time window cannot become earl | exception | error | flink, datastream-v2, windowing, session-windows, two-input, event-time, late-data |
| The end timestamp of a processing-time window cannot become | exception | error | flink, datastream-v2, windowing, session-windows, two-input, processing-time, backpressure |
| Window {window} is not in in-flight window set. | exception | error | flink, datastream-v2, windowing, session-windows, two-input, merging-window-set, state-consistency |
| The window uses a merging assigner, but the window state is | exception | critical | flink, datastream-v2, windowing, session-windows, two-output, state-backend, operator-init |
| The end timestamp of an event-time window cannot become earl | exception | error | flink, datastream-v2, windowing, session-windows, two-output, event-time, late-data |
| The end timestamp of a processing-time window cannot become | exception | error | flink, datastream-v2, windowing, session-windows, two-output, processing-time, backpressure |
| Window {window} is not in in-flight window set. | exception | error | flink, datastream-v2, windowing, session-windows, two-output, merging-window-set, state-consistency |
| Unsupported type of window strategy : {strategyClass} | exception | critical | flink, datastream-v2, windowing, window-strategy, job-translation, version-mismatch |
| Unsupported time type : {} | validation | critical | flink, datastream-v2, windowing, window-strategy, enum, version-mismatch, job-translation |
| The key is only defined for keyed operator | exception | error | |
| The key is only defined for keyed operator | exception | error | |
| The key is only defined for keyed operator | exception | error | |
| The key is only defined for keyed operator | exception | error | |
| A side output with a matching id was already requested with | validation | error | |
| Key types if input KeyedStreams don't match: {} and {}. | validation | error | |
| Unsupported type of sink, please use DataStreamV2SinkUtils t | validation | error | |
| Unexpected Redistribution Mode %s | validation | error | |
| Sink with pre-write topology is not supported for DataStream | exception | error | |
| Sink with pre-commit topology is not supported for DataStrea | exception | error | |
| Sink with post-commit topology is not supported for DataStre | exception | error | |
| Please ensure that flink-datastream in your class path | exception | error | |
| Please ensure that flink-datastream in your class path | exception | error | |
| Please ensure that flink-datastream in your class path | exception | error | |
| Unknown retry policy: {} | validation | error | |
| GPU discovery script ('%s') is not configured. | validation | error | |
| The gpu discovery script does not exist in path %s. | exception | error | gpu, external-resources, configuration, file-not-found |
| The discovery script %s is not executable. | exception | error | gpu, external-resources, permissions, configuration |
| The discovery script executed for over %d ms. | exception | error | gpu, timeout, process, external-resources |
| Discovery script exit with non-zero return code: %s. | exception | error | gpu, process-exit-code, external-resources, diagnostics |
| Unable to recover the job as the expected {} file is not fou | exception | critical | azure, abfs, recovery, file-sink, io |
| Unable to create recoverable outputstream as length of file | exception | critical | azure, abfs, recovery, truncation, file-sink |
| Unable to recover. Rename operation failed | exception | error | azure, abfs, rename, recovery, permissions |
| Cannot clean commit: Staging file does not exist. | exception | error | azure, abfs, commit, io, misleading-message |
| The src file {} with length {} does not match the expected l | exception | error | azure, abfs, commit, consistency, file-sink |
| Committing file by rename failed: {} to {} | exception | error | azure, abfs, commit, rename, permissions |
| Unrecoverable exception while trying to recover {} | exception | critical | azure, abfs, commit, savepoint-recovery, data-loss |
| Recoverable writers on AzureBlob are only supported for ABFS | exception | error | azure, abfs, wasb, scheme, file-sink |
| Unable to retrieve Azure storage key from environment. "{}" | exception | error | azure, credentials, environment, configuration |
| Failed to initialize GoogleHadoopFileSystem | exception | error | gcs, google-cloud, credentials, filesystem, initialization |
| Bucket name in %s is invalid | validation | error | gcs, uri, validation, configuration |
| Object name in %s is invalid | validation | error | gcs, uri, validation |
| Failed to read metadata for blob %s | exception | error | gcs, checksum, metadata, consistency, write |
| Checksum mismatch writing blob %s: expected %s but found %s | exception | critical | gcs, checksum, data-corruption, write, consistency |
| Serialized data with version %d cannot be read by serializer | exception | error | serialization, version-mismatch, gcs, checkpoint-restore |
| Illegal attempt to write to closed output stream | exception | error | gcs, output-stream, lifecycle, io |
| WriteChannel.write wrote %d of %d requested bytes, failing. | exception | error | gcs, partial-write, io, network |
| Blob %s already exists during attempted commit | exception | error | gcs, commit, idempotency, recovery |
| Serialized data with version %d cannot be read by serializer | exception | error | serialization, version-mismatch, gcs, resume |
| Hostname ${originalHostname} starts with a ${DOMAIN_SEPARATO | exception | warning | hdfs, hostname, block-location, malformed-data |
| file is not an instance of DistributedFileStatus | exception | error | hdfs, type-mismatch, block-location, api-misuse |
| Hadoop File System abstraction does not support scheme '${sc | exception | error | hdfs, classpath, filesystem-scheme, configuration |
| The given file system URI (${fsUri}) did not describe the au | exception | error | hdfs, configuration, uri, fs-defaultfs |
| The given file system URI (${fsUri}) did not describe the au | exception | error | hdfs, configuration, invalid-uri, fs-defaultfs |
| The given file system URI (${fsUri}) did not describe the au | exception | error | hdfs, configuration, fs-defaultfs, uri |
| The Hadoop file system's authority (${initUri.getAuthority() | exception | error | hdfs, dns, network, configuration |
| Cannot support file system for '${fsUri.getScheme()}' via Ha | exception | error | hdfs, classpath, dependency-conflict, linkage-error |
| Cannot instantiate file system for URI: ${fsUri} | exception | error | hdfs, wrapper-exception, configuration, initialization |
| Truncate failed: ${tempFile} (requested=${recoverable.offset | exception | error | hdfs, truncate, recovery, file-sink |
| Problem while truncating file: ${path} | exception | error | hdfs, truncate, recovery, wrapper-exception |
| Could not find a public truncate method on the Hadoop File S | exception | error | hdfs, hadoop-version, reflection, truncate |
| Truncation is not available in hadoop version < 2.7 , You ar | exception | error | hdfs, hadoop-version, truncate, unsupported-operation |
| Truncation of file failed because of access/linking problems | exception | error | hdfs, dependency-conflict, classloading, truncate |
| Truncation handle has not been initialized | exception | error | hadoop, hdfs, file-sink, truncation, reflection, streaming-files |
| Cannot clean commit: Staging file does not exist. | exception | error | hdfs, file-sink, commit, staging-file, recovery |
| Cannot clean commit: File has trailing junk data. | exception | error | hdfs, file-sink, commit, consistency, recovery |
| Corrupt data: Unexpected magic number ${byteBuffer.getInt()} | exception | error | oss, serialization, corrupt-state, magic-number |
| Failed to parse XML document with handler {} | exception | error | |
| Failed to sanitize XML document destined for handler {} | exception | error | |
| Invalid value for IsTruncated field: {} | exception | error | |
| Invalid character in value for {} : {} | validation | error | |
| {} must configure a value > 0 | validation | error | |
| {} | exception | error | |
| Entropy length must be >= 0 when entropy injection key is se | validation | error | |
| Failed to cast s5cmd spell [{}] [exit code = %d] [cfg: {}] m | exception | error | |
| This s3 file system implementation does not support recovera | exception | error | |
| Dynamic session credentials for Flink | exception | error | |
| Interrupted while waiting for part uploads to complete | exception | error | |
| Uploading parts failed | exception | error | |
| Inconsistent result for object %s: conflicting lengths. Reco | exception | error | |
| Recovering commit failed for object %s. Object does not exis | exception | error | |
| interrupted | exception | error | |
| Error recovering writer: Downloading the last data chunk fil | exception | error | |
| Unrecognized version or corrupt state: {} | exception | error | |
| Corrupt data: Unexpected magic number. | exception | error | s3, serialization, state-restore, corruption |
| S3 File System cannot recover recoverable for other file sys | validation | error | s3, api-misuse, recoverable-writer, type-check |
| Error recovering writer: Downloading the last data chunk fil | exception | error | s3, multipart-upload, recovery, data-integrity |
| Invalid assume-role.session-duration '%s' for bucket '%s'. M | validation | error | s3, configuration, assume-role, validation |
| Invalid path-style-access '%s' for bucket '%s'. Must be 'tru | validation | error | s3, configuration, path-style-access, validation |
| Only S3 to local copies are currently supported: {} -> {} | exception | error | s3, bulk-copy, unsupported-operation, api-misuse |
| Bulk copy interrupted | exception | warning | s3, bulk-copy, interruption, cancellation |
| S3 connection pool exhausted during bulk copy. The configure | exception | error | s3, bulk-copy, connection-pool, configuration, throughput |
| Bulk copy failed | exception | error | s3, bulk-copy, wrapper-exception, diagnostics |
| Entropy length must be >= 0 when entropy injection key is se | validation | error | s3, configuration, entropy-injection, validation |
| File not found: {} | exception | error | s3, file-not-found, path-handling, object-store-semantics |
| Directory not empty and recursive = false | exception | error | s3, delete, directory, object-store-semantics |
| Failed to delete: {} | exception | error | s3, delete, permissions, aws-sdk |
| File already exists: {} | exception | error | s3, create, overwrite-mode, idempotency |
| NativeS3FileSystem does not support renaming directories: {} | exception | error | s3, rename, directory, object-store-semantics, unsupported-operation |
| Failed to rename {} to {} | exception | error | s3, rename, permissions, aws-sdk |
| Bulk copy not enabled. Set s3.bulk-copy.enabled=true | exception | error | s3, bulk-copy, configuration, feature-flag |
| Recoverable writer not available | exception | error | s3, recoverable-writer, unsupported-operation, configuration |
| FileSystem has been closed for bucket: {}. Operations are no | exception | error | s3, lifecycle, use-after-close, filesystem-cache |
| Invalid S3 URI: missing or empty bucket name in URI: {} | exception | error | s3, uri-parsing, configuration, validation |
| Invalid character in entropy injection key: {} | validation | error | |
| s3.entropy.length must be > 0 | validation | error | |
| Failed to open S3 stream for {}/{} | exception | error | |
| Stream is closed | exception | error | |
| Cannot seek to negative position: {} | exception | error | |
| Cannot seek past end of stream: position={}, length={} | exception | error | |
| Read buffer must not be null | validation | error | |
| Range [off=%d, len=%d] out of bounds for buffer of length %d | validation | error | |
| Interrupted while acquiring lock | exception | error | |
| Stream is closed | exception | error | |
| Bucket name must not be null or empty | validation | error | |
| Bucket '%s': both 's3.bucket.%s.access-key' and 's3.bucket.% | validation | error | |
| S3ClientProvider has been closed | exception | error | lifecycle, s3, resource-management, concurrency, flink |
| CRT transport requested (s3.crt.enabled=true) but the aws-cr | exception | critical | s3, crt, classpath, plugins, deployment, flink |
| fs.s3.aws.credentials.provider is set but contains no valid | validation | error | configuration, credentials, s3, flink-conf, flink |
| Class {} does not implement AwsCredentialsProvider | validation | error | configuration, credentials, aws-sdk-v2, migration, s3, flink |
| Failed to instantiate credentials provider: {} | validation | error | credentials, reflection, configuration, aws-sdk-v2, s3, flink |
| AWS region could not be determined. Set 's3.region' in Flink | validation | error | configuration, region, s3, minio, aws-sdk-v2, flink |
| Unknown encryption type: {}. Supported values: none, sse-s3, | validation | error | configuration, encryption, sse, kms, s3, flink |
| Cannot commit empty multipart upload for object: {}. This in | exception | error | multipart-upload, writer, recoverable-state, programming-error, s3, flink |
| Failed to start multipart upload for key: {} | exception | error | s3, multipart-upload, iam, permissions, network, flink |
| Failed to upload part %d for key: %s, uploadId: %s | exception | error | s3, multipart-upload, network, retry, credentials, flink |
| Failed to put object for key: {} | exception | error | s3, upload, iam, permissions, configuration, flink |
| Interrupted while uploading object for key: {} | exception | warning | s3, interruption, cancellation, transfer-manager, concurrency, flink |
| Failed to async upload object for key: {} | exception | error | s3, transfer-manager, async, network, retry, flink |
| Failed to complete multipart upload for key: {} | exception | error | s3, multipart-upload, recovery, lifecycle-rules, commit, flink |
| Failed to abort multipart upload for key: %s, uploadId: %s | exception | warning | s3, multipart-upload, cleanup, idempotency, iam, flink |
| Failed to get object for key: {} | exception | error | s3, filesystem, network, io, recovery |
| Failed to get metadata for key: {} | exception | error | s3, filesystem, metadata, permissions, io |
| Incomplete-tail file does not exist: {} | exception | error | s3, recovery, local-state, filesystem, io |
| Stream is closed | exception | error | s3, stream, lifecycle, io |
| Stream is already closed | exception | error | s3, stream, commit, lifecycle, io |
| interrupted while acquiring lock | exception | warning | s3, concurrency, interruption, cancellation, io |
| Unsupported version: {} | exception | critical | s3, serialization, versioning, state-compat, checkpoint |
| Incomplete-tail object {} is referenced with non-positive le | exception | critical | s3, recovery, state-corruption, checkpoint, invariant |
| Cannot create local tmp dir: {} | exception | error | s3, local-disk, permissions, recovery, config |
| Incomplete-tail object {} has unexpected length (expected {} | exception | critical | s3, recovery, state-corruption, lifecycle-rules, checkpoint |
| Native S3 File System cannot recover recoverable for other f | validation | error | s3, type-mismatch, filesystem, recovery, config |
| RecoverableWriter has been closed | validation | error | s3, lifecycle, writer, state, io |
| Error in s3 aws URI - {} | exception | error | s3, presto, config, uri, startup |
| Interrupted while waiting for the previous batch to be consu | exception | warning | avro, format, interruption, cancellation, concurrency |
| Encountered exception when reading from avro format file | exception | error | avro, format, data-corruption, io, codec |
| no codec for codecByte: {} | validation | error | avro, format, codec, validation, versioning |
| Schema must be set when using Generic Record | validation | error | avro, flink, batch, schema, configuration |
| Failed to deserialize Avro record. | exception | error | avro, flink, deserialization, schema-evolution, kafka |
| Failed to serialize row. | exception | error | avro, flink, serialization, nullability, rowdata |
| Failed to serialize schema registry. | exception | error | avro, flink, serialization, schema-mismatch |
| Failed to create Avro encoder. | exception | error | avro, flink, json-encoding, schema-validation |
| Unsupported type: {} | validation | error | avro, flink, timestamp, legacy-mapping, configuration |
| Unexpected object type for TIMESTAMP logical type. Received: | validation | error | avro, flink, timestamp, schema-mismatch, logical-type |
| Unexpected object type for DATE logical type. Received: {} | validation | error | avro, flink, date, logical-type, schema-mismatch |
| Unexpected object type for TIME logical type. Received: {} | validation | error | avro, flink, time, logical-type, schema-mismatch |
| Avro Union with NULL type is only supported. Unsupported typ | validation | error | avro, flink, variant, union, schema |
| Unsupported type: {} | validation | error | avro, flink, variant, unsupported-type, fixed |
| Failed to serialize schema registry. | exception | error | avro, flink, schema-registry, confluent, network, serialization |
| Unsupported type: {} | validation | error | avro, flink, timestamp-ltz, legacy-mapping, serialization |
| The Avro schema is not a nullable type: %s | exception | error | avro, flink, union, nullable, schema |
| Fail to serialize at field: %s. | exception | error | avro, flink, field-mapping, nullability, debugging |
| Could not access the MODEL$ field of avro record | exception | error | avro, flink, reflection, classloader, jvm-modules |
| Could not parse Avro schema string. | exception | error | avro, flink, schema-parsing, json, configuration |
| Unsupported Avro type '%s'. | exception | error | avro, flink, fixed-type, type-mapping, schema |
| Avro does not support TIMESTAMP type with precision: %s, it | exception | error | avro, timestamp, precision, flink, schema-conversion |
| Avro does not support LOCAL TIMESTAMP type with precision: % | exception | error | avro, timestamp, precision, flink, schema-conversion |
| Unsupported to derive Schema for type: %s | exception | error | avro, timestamp-ltz, flink, schema-conversion, legacy |
| Avro does not support TIMESTAMP type with precision: %s, it | exception | error | avro, timestamp-ltz, precision, flink, schema-conversion |
| Avro does not support TIME type with precision: %s, it only | exception | error | avro, time, precision, flink, schema-conversion |
| Avro format doesn't support non-string as key type of map. T | exception | error | avro, map-key, flink, schema-conversion, type-mapping |
| Failed to Java-Deserialize an AvroSerializer instance. Was e | exception | critical | avro, state-restore, checkpoint, serialization, flink |
| unknown snapshot version for AvroSerializerSnapshot %s | exception | critical | avro, state-restore, snapshot-version, checkpoint, flink |
| Unable to find the class '%s' which is used to deserialize t | exception | critical | avro, state-restore, classloader, class-not-found, flink |
| Illegal count (must be non-negative): %s | exception | error | avro, serialization, internal, flink |
| Unknown data format. Magic number does not match | exception | error | avro, confluent, schema-registry, wire-format, kafka, flink |
| Could not find schema with id %s in registry | exception | error | avro, confluent, schema-registry, network, kafka, flink |
| Could not register schema in registry | exception | error | avro, confluent, schema-registry, schema-evolution, auth, flink |
| Option %s.%s is required for serialization | validation | error | avro, confluent, schema-registry, validation, flink, config |
| Schema provided for '%s' format does not match the table sch | exception | error | avro, confluent, schema-mismatch, validation, flink |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | avro, debezium, cdc, api-misuse, flink |
| The "before" field of %s message is null, if you are using D | exception | error | avro, debezium, postgres, cdc, replica-identity, flink |
| Unknown "op" value "%s". The Debezium Avro message is '%s' | exception | error | debezium, avro, schema-registry, kafka, serialization |
| Can't deserialize Debezium Avro message. | exception | error | debezium, avro, wrapper-exception, serialization, diagnostics |
| Schema provided for '%s' format must be a nullable record ty | exception | error | debezium, avro, schema-validation, format-options |
| Unsupported operation '%s' for row kind. | exception | error | debezium, avro, row-kind, serialization |
| Could not serialize row '%s'. | exception | error | debezium, avro, wrapper-exception, serialization, diagnostics |
| Unable to load the provided Hadoop codec [%s] | exception | error | hadoop, compression, codec, filesystem, configuration |
| Could not create CSV generator. | exception | error | csv, jackson, bulk-writer, filesystem, io |
| Format cannot define a quote character and disabled quote ch | validation | error | csv, validation, format-options, ddl |
| Option '%s.%s' must be a string with single character, but w | validation | error | csv, validation, format-options, delimiter |
| Failed to deserialize CSV row '%s'. | exception | error | csv, deserialization, dirty-data, kafka, parsing |
| Could not serialize row '%s'. | exception | error | csv, serialization, wrapper-exception, row-data |
| Unsupported type information '%s' for field '%s'. | exception | error | csv, schema, type-information, unsupported-type |
| Unsupported type '%s' for field '%s'. | exception | error | csv, schema, logical-type, unsupported-type |
| Only simple types are supported in the second level nesting | exception | error | csv, nesting, type-information, unsupported-type |
| Fail to deserialize at field: %s. | exception | error | csv, parsing, field-conversion, dirty-data |
| Unsupported type: %s | exception | error | csv, unsupported-type, map, deserialization |
| Csv does not support TIME type with precision: %s, it only s | exception | error | csv, time, precision, unsupported-type, ddl |
| Unable to deserialize byte array. | exception | error | |
| Row length mismatch. %s fields expected but was %s. | exception | error | |
| Failed to deserialize CSV row. | exception | error | |
| Unsupported type information '%s'. | exception | error | |
| Unable to deserialize byte array. | exception | error | |
| Row length mismatch. %s fields expected but was %s. | exception | error | |
| Row type information expected. | exception | error | |
| Fail to serialize at field: %s. | exception | error | |
| Unsupported type: %s | exception | error | |
| The path based writers do not support persisting | exception | error | |
| Only HadoopPathBasedPendingFileRecoverable is supported. | exception | error | |
| Unrecognized version or corrupt state: %s | exception | error | |
| Corrupt data: Unexpected magic number. | exception | error | |
| Persists the path-based part file write is not supported | exception | error | |
| Resume is not supported | exception | error | |
| In progress file(%s) not exists. | exception | error | flink, hadoop, filesystem, file-sink, commit, exactly-once |
| Could not commit file from %s to %s | exception | error | flink, hadoop, filesystem, rename, commit, io |
| JSON format doesn't support failOnMissingField and ignorePar | exception | error | flink, json, deserialization, config, validation |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | flink, json, deserialization, deprecated-api, array |
| Unsupported timestamp format '%s'. Validator should have che | exception | error | flink, json, options, timestamp, validation |
| Unsupported map null key handling mode '%s'. Validator shoul | exception | error | flink, json, options, map, validation |
| fail-on-missing-field and ignore-parse-errors shouldn't both | validation | error | flink, json, ddl, options, validation |
| Unsupported value '%s' for option %s. Supported values are % | validation | error | flink, json, options, map, sink, validation |
| Unsupported value '%s' for %s. Supported values are [SQL, IS | validation | error | flink, json, options, timestamp, validation |
| Failed to deserialize JSON '%s'. | exception | error | flink, json, deserialization, kafka, data-quality |
| Unsupported type: {} | exception | error | flink, json, schema, raw-type, converter |
| Numeric value (%s) out of range of Java byte. | exception | error | flink, json, tinyint, overflow, schema |
| Illegal JSON array data... | exception | error | flink, json, array, schema-mismatch, data-quality |
| JSON format doesn't support non-string as key type of map. T | exception | error | flink, json, map, schema, converter |
| Illegal JSON map data... | exception | error | flink, json, map, schema-mismatch, data-quality |
| Illegal JSON object data... | exception | error | flink, json, row, schema-mismatch, data-quality |
| Fail to deserialize at field: %s. | exception | error | flink, json, field-conversion, schema-drift, data-quality |
| Some field is missing in the JSON data. | exception | error | flink, json, missing-field, options, schema |
| Illegal Json Data... | exception | error | flink, json, nested-projection, row, data-quality |
| Some field is missing in the Json data. | exception | error | flink, json, missing-field, nested-projection, options |
| Failed to deserialize JSON '%s'. | exception | error | |
| Could not serialize row '%s'. | exception | error | |
| Invalid JSON schema. | validation | error | |
| Unsupported type '{}' in node: {} | validation | error | |
| Union types are such as 'allOf', 'anyOf' etc. and extending | validation | error | |
| No type could be found in node:{} | validation | error | |
| Union types with more than just a null type are not supporte | validation | error | |
| Invalid 'properties' property for object type in node: {} | validation | error | |
| An object must not allow additional properties in node: {} | validation | error | |
| Arrays must specify an 'items' property in node: {} | validation | error | |
| An array tuple must not allow additional items in node: {} | validation | error | |
| Invalid type for 'items' property in node: {} | validation | error | |
| Invalid 'format' property in node: {} | validation | error | |
| Invalid 'contentEncoding' property in node: {} | validation | error | |
| Invalid encoding '{}' in node: {} | validation | error | |
| Only JSON schemes with simple references (one indirection in | validation | error | |
| Could not find reference: {} | validation | error | |
| Cyclic references are not supported:{} | validation | error | |
| Could not serialize value '%s'. | exception | error | |
| Unsupported type: {} | exception | error | |
| Unable to deserialize VARIANT value. | exception | error | json, variant, deserialization, flink-json |
| Unable to deserialize byte array. | exception | error | json, binary, base64, deserialization, schema |
| JSON format doesn't support non-string as key type of map. T | exception | error | json, map, schema, deserialization, startup |
| Fail to deserialize at field: %s. | exception | error | json, row, field-conversion, runtime, schema-drift |
| Could not find field with name '%s'. | exception | error | json, missing-field, schema, option, runtime |
| Not support to parse type: %s | exception | error | json, raw-type, serialization, schema, startup |
| Unable to serialize VARIANT value. | exception | error | json, variant, serialization, version-mismatch |
| JSON format doesn't support non-string as key type of map. T | exception | error | json, map, schema, serialization, startup |
| JSON format doesn't support to serialize map data with null | exception | error | json, map, null-key, option, serialization |
| Fail to serialize at field: %s. | exception | error | json, row, field-conversion, serialization, runtime |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | canal, cdc, api-misuse, deserialization |
| Unknown "type" value "%s". The Canal JSON message is '%s' | exception | error | canal, cdc, unknown-type, option, runtime |
| Corrupt Canal JSON message '%s'. | exception | error | canal, cdc, corrupt-message, kafka, runtime |
| Could not serialize row '%s'. | exception | error | canal, cdc, serialization, runtime |
| Unsupported operation '%s' for row kind. | exception | error | canal, cdc, row-kind, serialization |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | debezium, cdc, api-misuse, deserialization |
| The "before" field of %s message is null, if you are using D | exception | critical | debezium, postgres, replica-identity, cdc, update |
| Unknown "op" value "%s". The Debezium JSON message is '%s' | exception | error | debezium, cdc, unknown-op, option, runtime |
| Corrupt Debezium JSON message '%s'. | exception | error | debezium, cdc, corrupt-message, kafka, runtime |
| Debezium JSON serialization doesn't support '%s.%s' option b | validation | error | flink, debezium, json, cdc, table-api, validation |
| Unsupported operation '%s' for row kind. | exception | error | flink, debezium, json, serialization, rowkind |
| Could not serialize row '%s'. | exception | error | flink, debezium, json, serialization, wrapper-exception |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | flink, maxwell, json, deserialization, api-misuse |
| Unknown "type" value "%s". The Maxwell JSON message is '%s' | exception | error | flink, maxwell, json, cdc, parse-error |
| Corrupt Maxwell JSON message '%s'. | exception | error | flink, maxwell, json, deserialization, corrupt-data |
| Unsupported operation '%s' for row kind. | exception | error | flink, maxwell, json, serialization, rowkind |
| Please invoke DeserializationSchema#deserialize(byte[], Coll | exception | error | flink, ogg, json, deserialization, api-misuse |
| The "before" field of %s message is null, if you are using O | exception | critical | flink, ogg, json, cdc, postgres, replica-identity |
| Unknown "op_type" value "%s". The Ogg JSON message is '%s' | exception | error | flink, ogg, json, cdc, parse-error |
| Corrupt Ogg JSON message '%s'. | exception | error | flink, ogg, json, deserialization, corrupt-data |
| Unsupported operation '%s' for row kind. | exception | error | flink, ogg, json, serialization, rowkind |
| Could not serialize row '%s'. | exception | error | flink, ogg, json, serialization, wrapper-exception |
| Interrupted | exception | warning | flink, orc, interrupt, shutdown, filesystem-source |
| Invalid binary comparison. | exception | error | flink, orc, predicate-pushdown, expression, filters |
| A predicate on a LONG column requires an integer literal, i. | exception | error | flink, orc, predicate-pushdown, type-mismatch, bigint |
| A predicate on a FLOAT column requires a floating literal, i | exception | error | flink, orc, predicate-pushdown, type-mismatch, double |
| A predicate on a STRING column requires a floating literal, | exception | error | flink, orc, predicate-pushdown, type-mismatch, string, misleading-message |
| A predicate on a BOOLEAN column requires a Boolean literal. | exception | error | flink, orc, predicate-pushdown, type-mismatch, boolean |
| A predicate on a DATE column requires a java.sql.Date litera | validation | error | |
| A predicate on a TIMESTAMP column requires a java.sql.Timest | validation | error | |
| A predicate on a DECIMAL column requires a BigDecimal litera | validation | error | |
| Unknown literal type {} | validation | error | |
| Not support other binary type: {} | validation | error | |
| Unsupported type: {} | validation | error | |
| Unsupported hive version for orc shim: {} | validation | error | |
| Could not deserialize Hadoop Configuration, the serialized a | exception | error | |
| Unsupported vector: {} | validation | error | |
| Unsupported type: {} | validation | error | |
| Unsupported type: {} | validation | error | |
| PostScript too large at {} | validation | error | |
| Unsupported type: {} | validation | error | |
| Unsupported vector: {} | validation | error | |
| Unsupported type: {} | validation | error | |
| Parquet with case insensitive mode should have no duplicate | exception | error | |
| The quality of field type is incompatible with the request s | exception | error | |
| Schema evolution not supported. | validation | error | |
| Required column is missing in data file. Col: {} | exception | error | |
| expecting more rows but reached last block. Read {} out of { | exception | error | |
| Only support seek at first. | validation | error | parquet, seek, streaming, flink |
| Interrupted | exception | error | parquet, interruption, cancellation, concurrency |
| A stream against this file was already created. | exception | error | parquet, output-stream, single-use, flink |
| Please use AvroParquetReaders.forSpecificRecord(Class<T>) fo | validation | error | parquet, avro, api-misuse, flink |
| Please use AvroParquetReaders.forGenericRecord(Class<T>) for | validation | error | parquet, avro, schema, api-misuse |
| Current version of AvroParquetRecordFormat is not splittable | validation | error | parquet, avro, splitting, file-source |
| Protocol buffer class or descriptor not specified. Please us | validation | error | parquet, protobuf, configuration, flink |
| Expected two fields for the map (key/value), but got: {} | validation | error | parquet, protobuf, map, schema |
| Protocol Buffers editions syntax is not supported | validation | error | parquet, protobuf, editions, compatibility |
| Cannot convert Protobuf message with extension field(s) | validation | error | parquet, protobuf, extensions, proto2 |
| FieldIndex mismatch name={}: {} != {} | validation | error | parquet, protobuf, schema-evolution, field-order |
| Unknown type with descriptor "{}" and type "{}." | validation | error | parquet, protobuf, unsupported-type, schema |
| Failed to delegate to ProtoSchemaConverter | exception | error | parquet, protobuf, classpath, reflection, dependency |
| Unsupported type: {} | exception | error | parquet, row-data, type-system, flink-sql |
| Parquet does not support null keys in maps. See https://gith | validation | error | parquet, map, null-key, data-quality |
| Time unit not recognized | exception | error | parquet, timestamp, time-unit, flink-sql |
| Offset is not monotonically ascending. offsets[%s]=%s, offse | validation | error | parquet, nested-types, offsets, corruption, reader |
| Unsupported type: {} | exception | error | parquet, schema-conversion, unsupported-type, flink-sql |
| {} does not exist | validation | error | parquet, schema-mismatch, projection, case-sensitivity |
| Parquet with case insensitive mode should have no duplicate | exception | error | parquet, schema, case-insensitive, flink |
| The quality of field type is incompatible with the request s | exception | error | parquet, schema, internal-invariant, flink |
| Schema evolution not supported. | exception | error | parquet, schema-evolution, type-mismatch, flink |
| Required column is missing in data file. Col: {} | exception | error | parquet, schema-evolution, required-column, flink |
| expecting more rows but reached last block. Read {} out of { | exception | error | parquet, corruption, row-group, io, flink |
| Only support seek at first. | exception | error | parquet, seek, api-misuse, flink |
| Seek to many rows. | exception | error | parquet, seek, metadata-mismatch, flink |
| Unsupported type: {} | exception | error | parquet, unsupported-type, vectorized-reader, flink |
| Corrupted Parquet schema | validation | error | parquet, schema, corruption, nested-types, flink |
| Failed to find related Parquet column descriptor with type { | validation | error | parquet, schema, nested-types, column-not-found, flink |
| {} is not supported now. | exception | error | parquet, unsupported-type, flink |
| Unknown ColumnIO, %s | exception | error | parquet, corruption, array, internal-invariant, flink |
| Can not find column io for parquet reader. | exception | error | parquet, schema, nested-types, column-not-found, flink |
| could not decode the dictionary for {} | exception | error | parquet, encoding, dictionary, corruption, io, flink |
| totalValueCount == 0 | exception | error | parquet, corruption, metadata, io, flink |
| Unsupported page type: {} | exception | error | parquet, version-conflict, page, classpath, flink |
| Unsupported encoding: {} | exception | error | parquet, encoding, legacy-format, flink |
| could not read page {} in col {} | exception | error | parquet, corruption, io, page, flink |
| could not read page in col {} as the dictionary was missing | exception | error | |
| could not read dictionary in col {} | exception | error | |
| Failed to read {} bytes | exception | error | |
| Failed to read a byte | exception | error | |
| Row field does not have any children: %s. | exception | error | |
| Could not decode the dictionary for %s | exception | error | |
| Unsupported type in the list: | exception | error | |
| Could not read page in col %s because the dictionary was mis | exception | error | |
| Could not read page in col %s. | exception | error | |
| Could not read page %s in col %s. | exception | error | |
| Could not read levels in page for col %s. | exception | error | |
| Unsupported operation | exception | error | |
| not a valid mode | exception | error | |
| Failed to read from input stream | exception | error | parquet, io, data-corruption, flink-formats |
| Invalid time unit: | exception | error | parquet, timestamp, version-conflict, flink-formats |
| The 'protobuf' format is not supported for the 'filesystem' | validation | error | protobuf, filesystem-connector, ddl, validation |
| Do not support flink type: | exception | error | protobuf, codegen, schema, type-mapping |
| Illegal type for protobuf enum, only char/vachar/int/bigint | exception | error | protobuf, enum, codegen, schema |
| Unsupported protobuf simple type: | exception | error | protobuf, codegen, schema-mismatch |
| Failed to deserialize PB object. | exception | error | protobuf, kafka, deserialization, poison-pill |
| Do not support flink data type: | exception | error | protobuf, codegen, serialization, type-mapping |
| Unsupported data type in schema: | exception | error | protobuf, codegen, serialization, schema |
| Unsupported data type in schema: | exception | error | protobuf, codegen, rowdata, type-mapping |
| do not support field type: | exception | error | protobuf, codegen, version-conflict |
| Program cannot be compiled. This is a bug. Please file an is | exception | critical | protobuf, codegen, janino, compile-error, bug |
| get %s descriptors error! | exception | error | protobuf, classpath, reflection, configuration |
| Column | validation | error | protobuf, schema-validation, ddl, naming |
| Unexpected LogicalType: | validation | error | protobuf, schema-validation, row-type, ddl |