状態の読み込み中にエラーが発生しました。
自動スナップショット修復失敗
ステートストア<latestSnapshot>のスナップショットバージョン<stateStoreId>を読み込めませんでした。 使用可能なスナップショット (<selectedSnapshots>) の中からスナップショットバージョン (<eligibleSnapshots>) を用いた自動修復も失敗しました。
CANNOT_FIND_BASE_SNAPSHOT_CHECKPOINT
系列が含まれたベース スナップショット チェックポイントが見つかりません: <lineage>。
CANNOT_READ_CHECKPOINT
RocksDB のチェックポイントのメタデータを読み取れません。
<expectedVersion> を想定しましたが、実際は <actualVersion> が見つかりました。
CANNOT_READ_DELTA_FILE_KEY_SIZE
<clazz> 件のうち <fileToRead> 件目の差分ファイルの読み取りにエラーが発生しました: キーのサイズは <keySize> にできません。
CANNOT_READ_DELTA_FILE_NOT_EXISTS
<clazz> 件のうち <fileToRead> 件目の差分ファイルの読み取り中にエラーが発生しました: <fileToRead> が存在しません。
CANNOT_READ_MISSING_SNAPSHOT_FILE
<clazz> 件のうち <fileToRead> 件目のスナップショット ファイルの読み取り中にエラーが発生しました: <fileToRead> が存在しません。
CANNOT_READ_SNAPSHOT_FILE_KEY_SIZE
<clazz> 件のうち <fileToRead> 件目のスナップショット ファイルの読み取りにエラーが発生しました: キーのサイズは <keySize> にできません。
CANNOT_READ_SNAPSHOT_FILE_VALUE_SIZE
<clazz> 件のうち <fileToRead> 件目のスナップショット ファイルの読み取りにエラーが発生しました: 値のサイズは <valueSize> にできません。
CANNOT_READ_STREAMING_STATE_FILE
<clazz> のストリーミング状態ファイルの読み取り中にエラーが発生しました: <fileToRead>が存在しません。 ストリーム ジョブが、新しい状態操作または更新された状態操作とともに再起動される場合は、新しいチェックポイントの保存先を作成するか、既存のチェックポイントの保存先をクリアしてください。
CANNOT_WRITE_STREAMING_STATE_FILE
チェックポイントの場所が読み取り専用であるか、または ID に書き込みアクセス許可がないため、ストリーミング状態ストア ファイルへの書き込みに失敗しました。 チェックポイントの場所が書き込み可能であることを確認してください。 エラー メッセージ: <errorMsg>
チェックポイントファイルのチェックサム検証に失敗しました
<originalMessage>
CONFIGURATION_MISMATCH
状態ストアの構成がチェックポイントの構成と一致しないため、状態ストアの読み込みに失敗しました。 エラー メッセージ: <errorMsg>
CONNECTION_POOL_SHUT_DOWN
プロバイダー '<stateStoreId>' から ID '<stateStoreProviderName>' の状態ストアを読み込めませんでした。 取得されたエラー メッセージ: <errorMsg>
CONNECTION_REFUSED（接続拒否）
接続拒否エラーのため、プロバイダー <stateStoreId>から ID <stateStoreProviderName>を持つ状態ストアを読み込めませんでした。 エラー メッセージ: <errorMsg>
FAILED_TO_GET_CHANGELOG_WRITER
バージョン <version>で状態ストアの変更ログ ライターを取得できませんでした。
HDFS_STORE_PROVIDER_OUT_OF_MEMORY
メモリ不足の例外が発生したため、ID <stateStoreId> の HDFS の状態ストアを読み込めませんでした。
INCORRECT_NUMBER_FORMAT
状態ストアの読み込みに失敗しました。 取得されたエラー メッセージ: <errorMsg>
INVALID_CHANGE_LOG_READER_VERSION
変更ログ リーダーのバージョンは <version> 未満にできません。 チェックポイントはおそらく将来の Spark バージョンからであり、Spark をアップグレードしてください。
INVALID_CHANGE_LOG_WRITER_VERSION
変更ログ ライターのバージョンは <version> 未満にできません。
チェックポイントの系譜が無効です
チェックポイント系列が無効です: <lineage>。 <message>
KEY_ROW_FORMAT_VALIDATION_FAILURE
<msg>
LOCAL_DISK_ERROR
ローカル ディスク エラーが原因で、プロバイダー <stateStoreId>から ID <stateStoreProviderName>の状態ストアを読み込めませんでした。 その一般的な理由は、Executor のローカル ディスク領域が不足している可能性があります。
ROCKSDB_STORE_PROVIDER_OUT_OF_MEMORY
メモリ不足の例外が発生したため、ID <stateStoreId> の RocksDB の状態ストアを読み込めませんでした。
ROW_CHECKSUM_VERIFICATION_FAILED (行のチェックサム検証に失敗しました)
<originalMessage>
SNAPSHOT_PARTITION_ID_NOT_FOUND
<checkpointLocation> における演算子 <operatorId> の状態に対応するパーティション ID <snapshotPartitionId> が見つかりません。
UNCATEGORIZED
UNEXPECTED_FILE_SIZE
<dfsFile> を <localFile> にコピーしました。想定されるバイト数 <expectedSize> に対し、検出されたバイト数は <localFileSize> バイトでした。
UNEXPECTED_VERSION
バージョンは 0 以下にできないため、<version> にすることはできません。
UNRELEASED_THREAD_ERROR
<loggingId>: operationType=<operationType> に対して、<newAcquiredThreadInfo> が RocksDB インスタンスを取得できませんでした。<timeWaitedMs> ミリ秒経過後も <acquiredThreadInfo> によってインスタンスが解放されませんでした。
ロックを保持しているスレッドには、次のトレースがあります: <stackTraceOutput>
VALUE_ROW_FORMAT_VALIDATION_FAILURE
<msg>
VERSIONID_MISMATCH
RocksDB ローカル ファイルのバージョン ID が、バージョン <version>で作成されたものと一致しません。