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
ここでファイルを探しているのはなぜですか?