We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 72b6fe5 commit aba142dCopy full SHA for aba142d
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBLoader.scala
@@ -17,7 +17,7 @@
17
18
package org.apache.spark.sql.execution.streaming.state
19
20
-import org.rocksdb.RocksDB
+import org.rocksdb.{RocksDB => NativeRocksDB}
21
22
import org.apache.spark.internal.Logging
23
import org.apache.spark.util.UninterruptibleThread
@@ -36,7 +36,7 @@ object RocksDBLoader extends Logging {
36
override def run(): Unit = {
37
try {
38
runUninterruptibly {
39
- RocksDB.loadLibrary()
+ NativeRocksDB.loadLibrary()
40
exception = None
41
}
42
} catch {
0 commit comments