apache/flink
Documented errors, page 3 of 11. Back to apache/flink
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| WriteChannel.write wrote | exception | error | gcs, partial-write, io, network |
| Cannot find the partition value from path for partition | exception | error | |
| Fetch partitions fail. | exception | error | |
| Output path could not be initialized. | exception | error | flink, file-output, distributed-fs, hdfs, s3, write-mode |
| Program cannot be compiled. This is a bug. Please file an… | exception | critical | protobuf, codegen, janino, compile-error, bug |
| S3ClientProvider has been closed | exception | error | lifecycle, s3, resource-management, concurrency, flink |
| Streaming mode not support overwrite. | exception | error | table-sink, overwrite, streaming-mode, illegal-state, flink |
| conflicting non-public interface class loaders | exception | error | serialization, classloader, proxy, duplicate-classes |
| The parallelism must be a positive number | validation | error | cli, configuration, user-input |
| Workaround hack. | exception | error | comparator, internal-api, unsupported-operation |
| Can not new instance for custom class from | exception | error | |
| Corrupted Parquet schema | validation | error | parquet, schema, corruption, nested-types, flink |
| The given configuration directory name | validation | error | configuration, path, startup, environment, flink-core |
| This split reader does not support pausing or resuming… | exception | error | watermark-alignment, split-reader, config, flink-source |
| Could not instantiate class | exception | error | classloader, configuration, classpath, shading |
| The configured hostname is not valid | validation | error | network, configuration, hostname, ipv6, flink-core |
| Could not load the provided entrypoint class. | exception | error | |
| Unable to serialize default value of type | exception | error | state-descriptor, serialization, default-value, type-serializer |
| File with name ' ' is not available. Did you forget to… | validation | error | distributed-cache, registration, task, name-mismatch |
| JAR file is not a file | exception | error | parquet, timestamp, type-mismatch, double |
| No lambda method found. | exception | error | type-extraction, lambda, reflection, classloader |
| Primitive component expected. | exception | error | type-validation, primitive-array, type-mismatch, boxing, reflection, array |
| Could not load class… | exception | error | avro, missing-dependency, serializer, type-system |
| Required column is missing in data file. Col | exception | error | parquet, schema-evolution, required-column, flink |
| Failed to serialize value | exception | error | accumulator, serialization, kryo, type-serializer |
| The TypeHint is using a generic variable.This is not… | exception | error | type-information, type-hint, generics, type-erasure |
| Cannot terminate a standalone cluster. | exception | warning | deployment, standalone, unsupported-operation |
| Execution config has not been set properly for this plan | exception | error | plan, execution-config, optimizer, null-check |
| Failed to get the FileSystem of artifact | exception | error | filesystem, job-submission, distributed-cache, rest-client |
| Incompatible version: found | exception | error | serialization, version-mismatch, checkpoint-restore, versioned-io |
| Incomplete-tail object | exception | critical | s3, recovery, state-corruption, lifecycle-rules, checkpoint |
| Interrupted | exception | warning | flink, orc, interrupt, shutdown, filesystem-source |
| Could not serialize row | exception | error | flink, debezium, json, serialization, wrapper-exception |
| JAR file path invalid | exception | error | jar, url, validation, classpath |
| Unsupported operation | exception | error | flink, debezium, json, serialization, rowkind |
| Wrap is not supported by this segment. This usually… | exception | error | memory, bytebuffer, flink-core, ownership |
| Cannot create accumulator | exception | error | accumulator, reflection, runtime-context, user-error |
| Parallelism must be at least one, or… | validation | error | parallelism, execution-config, validation, config |
| The BulkIteration meta operator cannot have broadcast… | exception | error | bulk-iteration, broadcast-variable, unsupported-operation, dataset-api, flink-core |
| Corrupt Debezium JSON message | exception | error | debezium, cdc, corrupt-message, kafka, runtime |
| Could not create committable serializer. | exception | error | file-sink, filesystem, serializer, configuration, connectivity |
| Invalid input: Empty string | exception | error | parser, bigdecimal, empty-field, csv, flink-core |
| Could not determine type information from inputs. | exception | error | operators, null-check, union, flink-core |
| Do not support flink type: | exception | error | protobuf, codegen, schema, type-mapping |
| Encoded string is too long | exception | error | flink, serialization, record, utf, size-limit |
| Input types of coGroup must be composite types. | exception | error | cogroup-raw, type-system, comparator, invalid-program, dataset-api, flink-core |
| Cannot modify forwarded fields | exception | error | semantic-properties, immutable, unsupported-operation, flink-core |
| SimpleStreamFormat is not splittable, but found split end | exception | error | simple-stream-format, non-splittable, file-source, flink |
| The block size parameter must be set and larger than 0. | validation | error | input-format, binary, block-size, validation, illegal-argument |
| The missing type information cannot be used as a type… | exception | error | type-extraction, missing-type-info, type-info |
| Can not find format factory. | exception | error | table-sink, format-factory, writer-creation, table-exception, flink |
| Failed to deserialize coordination response | exception | error | serialization, rest-client, operator-coordination, classloader |
| The underlying input format to this ReplicatingInputFormat… | exception | error | input-format, runtime-context, api-misuse, broadcast |
| Truncate failed: (requested= ,size= ) | exception | error | hdfs, truncate, recovery, file-sink |
| Truncation handle has not been initialized | exception | error | hadoop, hdfs, file-sink, truncation, reflection, streaming-files |
| Debezium JSON serialization doesn't support | validation | error | flink, debezium, json, cdc, table-api, validation |
| Failed to get object for key | exception | error | s3, filesystem, network, io, recovery |
| Input type of GroupCombine must be one of composite types… | exception | error | group-combine, type-system, comparator, invalid-program, dataset-api, flink-core |
| Accessing a field by position is not supported in… | exception | error | flink, row, api-misuse, field-access, illegal-argument |
| text does not start with a number | exception | error | memory, parsing, number-format, configuration, flink-core-api |
| Unknown restart strategy | validation | error | restart-strategy, config, parsing, description |
| Could not get Splits. | exception | error | hadoop, mapreduce, input-format, splits, interrupted |
| offset: len: value.len | exception | error | flink, string-value, index-out-of-bounds, bounds-check |
| Output directory could not be created. | exception | error | flink, file-output, distributed-fs, hdfs, directory, write-mode |
| Exception in finalizeGlobal | exception | error | output-format, finalize-global, partition-commit, table-exception, flink |
| Invalid POJO field reference | exception | error | pojo, field-reference, type-system, keyby, flink-core |
| The accumulator object | exception | error | accumulator, type-mismatch, merge, naming |
| Cannot extract TypeInformation from Class alone, because… | exception | error | type-information, type-hint, generics, type-erasure |
| Error recovering writer: Downloading the last data chunk… | exception | error | s3, multipart-upload, recovery, data-integrity |
| expecting more rows but reached last block. Read | exception | error | parquet, corruption, row-group, io, flink |
| Failed to upload part | exception | error | s3, multipart-upload, network, retry, credentials, flink |
| Row arity of reuse ( ) or from ( ) is incompatible with… | exception | error | row, serializer, arity-mismatch, reuse, schema |
| The fetch size ( ) must be > 0, but is | exception | error | config, stream-format, fetch-size, illegal-config, flink |
| Could not find any format factory for identifier | validation | error | table-source, format-factory, validation, classloader, flink |
| Memory size unit ' ' does not match any of the recognized… | exception | error | memory, parsing, configuration, units, flink-core-api |
| The class declares a non-static main method. | exception | error | packaged-program, main-method, static-modifier |
| Unknown "type" value | exception | error | flink, maxwell, json, cdc, parse-error |
| Failed to create reader | exception | error | hybrid-source, source-reader, initialization, source-transition |
| Name, aggregator, or convergence criterion must not be null | validation | error | aggregator, iteration, convergence, null-check |
| offset= , numBytes= , address= | exception | error | memory, unsafe, flink-core, bounds-check |
| Option ' . ' must be a string with single character, but was | validation | error | csv, validation, format-options, delimiter |
| The runtime context has not been initialized yet. Try… | exception | error | lifecycle, runtime-context, output-format, flink-core |
| Can not find column io for parquet reader. | exception | error | parquet, schema, nested-types, column-not-found, flink |
| Cannot create Comparator for | exception | error | hadoop, type-info, comparator, writable, keyed |
| Could not close RecordReader. | exception | error | hadoop, mapreduce, output-format, interrupted, record-writer |
| do not support field type: | exception | error | protobuf, codegen, version-conflict |
| Exception in open | exception | error | output-format, open, partition-writer, table-exception, flink |
| Row arity of from ( ) does not match this serializer's… | exception | error | row, serializer, arity-mismatch, schema, position-based |
| Tuple0 cannot take any data, as it has zero fields. | exception | error | tuple, arity-mismatch, misuse, typeutils |
| Unsupported bitmap type | exception | error | bitmap, type-check, illegalargument, flink-core |
| JobConf may not be null. | validation | error | hadoop-compatibility, mapred, null-check, constructor |
| Unrecognized version for TypeSerializerSnapshot format | exception | critical | serialization, checkpoint, savepoint, version-mismatch, state, io |
| Write record failed | exception | error | output-format, async, io, error-handling |
| Blob already exists during attempted commit | exception | error | gcs, commit, idempotency, recovery |
| Could not get KeyValue pair. | exception | error | hadoop, mapreduce, input-format, interrupted, record-reader |
| The src file with length does not match the expected length | exception | error | azure, abfs, commit, consistency, file-sink |
| value overflow | exception | error | parsing, csv, long, overflow, flink-core |
| Basic type ' ' expected but was ' '. | exception | error | type-validation, basic-type, type-mismatch, reflection |
| Failed to serialize ExecutionPlan. | exception | error | serialization, job-submission, rest-client, io |
| Given class: is not a FunctionalInterface. | exception | error | type-extraction, functional-interface, lambda, reflection |