0

rocksdbjni 6.15.2 を使用して状態を管理およびチェックポイントするストリーミング パイプラインがあります。この同じライブラリを別のオフライン Scala プロセスで使用して、チェックポイント ファイルを読み取り、さらに処理を実行しようとしています。

テストするために、チェックポイント状態フォルダーの 1 つをローカル フォルダーにコピーしました。

ls /mnt/tmp/rocksdb/

010959.sst
CURRENT
MANIFEST-010701
OPTIONS-010704

次に、この単純な Scala プログラムを実行しました。

import org.rocksdb.{Options, RocksDB}

val dbPath = "/mnt/tmp/rocksdb"
val options = new Options().setCreateIfMissing(false)

RocksDB.loadLibrary()
val db: RocksDB = RocksDB.open(options, dbPath)

この例外に遭遇します:org.rocksdb.RocksDBException: Corruption: IO error: No such file or directoryWhile open a file for random read: /mnt/tmp/rocksdb/010958.ldb: No such file or directory

以前にこの例外に遭遇した人はいますか? RocksDB が.ldbここでファイルを探しているのはなぜですか?

4

0 に答える 0