CANNOT_LOAD_STATE_STORE error class
An error occurred during loading state.
CANNOT_READ_CHECKPOINT
Cannot read RocksDB checkpoint metadata. Expected <expectedVersion>
, but found <actualVersion>
.
CANNOT_READ_DELTA_FILE_KEY_SIZE
Error reading delta file <fileToRead>
of <clazz>
: key size cannot be <keySize>
.
CANNOT_READ_DELTA_FILE_NOT_EXISTS
Error reading delta file <fileToRead>
of <clazz>
: <fileToRead>
does not exist.
CANNOT_READ_MISSING_SNAPSHOT_FILE
Error reading snapshot file <fileToRead>
of <clazz>
: <fileToRead>
does not exist.
CANNOT_READ_SNAPSHOT_FILE_KEY_SIZE
Error reading snapshot file <fileToRead>
of <clazz>
: key size cannot be <keySize>
.
CANNOT_READ_SNAPSHOT_FILE_VALUE_SIZE
Error reading snapshot file <fileToRead>
of <clazz>
: value size cannot be <valueSize>
.
CANNOT_READ_STREAMING_STATE_FILE
Error reading streaming state file of <clazz>
: <fileToRead>
does not exist. If the stream job is restarted with a new or updated state operation, please create a new checkpoint location or clear the existing checkpoint location.
SNAPSHOT_PARTITION_ID_NOT_FOUND
Partition id <snapshotPartitionId>
not found for state of operator <operatorId>
at <checkpointLocation>
.
UNCATEGORIZED
UNEXPECTED_FILE_SIZE
Copied <dfsFile>
to <localFile>
, expected <expectedSize>
bytes, found <localFileSize>
bytes.
UNEXPECTED_VERSION
Version cannot be <version>
because it is less than 0.
UNRELEASED_THREAD_ERROR
<loggingId>
: RocksDB instance could not be acquired by <newAcquiredThreadInfo>
for operationType=<operationType>
as it was not released by <acquiredThreadInfo>
after <timeWaitedMs>
ms.
Thread holding the lock has trace: <stackTraceOutput>
VERSIONID_MISMATCH
Version Id of the RocksDB local file doesn't match the one created in version <version>
.