kondisi kesalahan CANNOT_LOAD_STATE_STORE

Terjadi kesalahan selama status pemuatan.

PERBAIKAN_CUCI_CETAK_OTOMATIS_GAGAL

Gagal memuat versi snapshot <latestSnapshot> untuk penyimpanan status <stateStoreId>. Upaya untuk memperbaiki otomatis menggunakan versi rekam jepret (<selectedSnapshots>) dari rekam jepret yang tersedia (<eligibleSnapshots>) juga gagal.

CANNOT_FIND_BASE_SNAPSHOT_CHECKPOINT

Tidak dapat menemukan titik pemeriksaan cuplikan dasar dengan silsilah: <lineage>.

CANNOT_READ_CHECKPOINT

Tidak dapat membaca metadata titik pemeriksaan RocksDB. Diharapkan <expectedVersion>, tetapi ditemukan <actualVersion>.

CANNOT_READ_DELTA_FILE_KEY_SIZE

Kesalahan saat membaca file delta <fileToRead> dari <clazz>: ukuran kunci tidak boleh <keySize>.

CANNOT_READ_DELTA_FILE_NOT_EXISTS

Kesalahan saat membaca file <fileToRead> delta dari <clazz>: <fileToRead> tidak ada.

CANNOT_READ_MISSING_SNAPSHOT_FILE

Kesalahan saat membaca file <fileToRead> rekam jepret dari <clazz>: <fileToRead> tidak ada.

CANNOT_READ_SNAPSHOT_FILE_KEY_SIZE

Kesalahan saat membaca file <fileToRead> cuplikan <clazz>: ukuran kunci tidak boleh <keySize>.

CANNOT_READ_SNAPSHOT_FILE_VALUE_SIZE

Kesalahan membaca file snapshot <fileToRead> dari <clazz>: ukuran nilai tidak boleh <valueSize>.

CANNOT_READ_STREAMING_STATE_FILE

Kesalahan saat membaca file <clazz>status streaming : <fileToRead> tidak ada. Jika Anda meluncurkan ulang pekerjaan streaming dengan operasi keadaan baru atau yang diperbarui, harap buat lokasi titik pemeriksaan baru atau hapus lokasi titik pemeriksaan yang ada.

VERIFIKASI CHECKSUM FILE CHECKPOINT GAGAL

<originalMessage>

CONFIGURATION_MISMATCH

Penyimpanan status gagal dimuat karena konfigurasi penyimpanan status tidak cocok dengan konfigurasi di titik pemeriksaan. Pesan kesalahan: <errorMsg>

CONNECTION_POOL_SHUT_DOWN

Gagal memuat penyimpanan status dengan ID '<stateStoreId>' dari penyedia '<stateStoreProviderName>'. Pesan kesalahan yang didapat: <errorMsg>

Sambungan Ditolak

Gagal memuat penyimpanan status dengan ID <stateStoreId> dari penyedia <stateStoreProviderName> disebabkan oleh kesalahan koneksi yang ditolak. Pesan kesalahan: <errorMsg>

FAILED_TO_GET_CHANGELOG_WRITER

Gagal mendapatkan penulis changelog untuk penyimpanan status pada versi <version>.

HDFS_STORE_PROVIDER_OUT_OF_MEMORY

Tidak dapat memuat penyimpanan status HDFS dengan id <stateStoreId> karena pengecualian kehabisan memori.

INCORRECT_NUMBER_FORMAT

Penyimpanan status gagal dimuat dengan sukses. Pesan kesalahan yang didapat: <errorMsg>

INVALID_CHANGE_LOG_READER_VERSION

Versi pembaca log perubahan tidak boleh <version>. Titik pemeriksaan mungkin berasal dari versi Spark di masa mendatang, silakan tingkatkan Spark Anda.

INVALID_CHANGE_LOG_WRITER_VERSION

Versi penulis log perubahan tidak boleh <version>.

"KETURUNAN_TITIK_PEMERIKSAAN_TIDAK_VALID"

Silsilah titik pemeriksaan tidak valid: <lineage>. <message>

KEY_ROW_FORMAT_VALIDATION_FAILURE

<msg>

LOCAL_DISK_ERROR

Gagal memuat penyimpanan status dengan ID <stateStoreId> dari penyedia <stateStoreProviderName> karena kesalahan disk lokal. Alasan umum untuk ini bisa kehabisan ruang disk lokal pada eksekutor.

ROCKSDB_STORE_PROVIDER_OUT_OF_MEMORY

Tidak dapat memuat penyimpanan status RocksDB dengan id <stateStoreId> karena pengecualian kehabisan memori.

ROW_CHECKSUM_VERIFICATION_FAILED

<originalMessage>

SNAPSHOT_PARTITION_ID_NOT_FOUND

Id partisi <snapshotPartitionId> tidak ditemukan untuk keadaan operator <operatorId> pada <checkpointLocation>.

UNCATEGORIZED

UNEXPECTED_FILE_SIZE

Disalin <dfsFile> ke <localFile>, diharapkan <expectedSize> byte, ditemukan <localFileSize> byte.

UNEXPECTED_VERSION

Versi tidak boleh <version> karena kurang dari 0.

UNRELEASED_THREAD_ERROR

<loggingId>: Instans RocksDB tidak dapat diperoleh oleh <newAcquiredThreadInfo> untuk operationType=<operationType> karena tidak dirilis oleh <acquiredThreadInfo> setelah <timeWaitedMs> ms.

Utas yang menahan kunci memiliki jejak: <stackTraceOutput>

VALUE_ROW_FORMAT_VALIDATION_FAILURE