Disable rocksdb wal for statemachine on raft mode

Change-Id: I59c9b174a57aaf3859067459dd3195960e6d8d3c
apache · Dec 28, 2020 · 3f5f469 · 3f5f469
1 parent 0f15c46
commit 3f5f469
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/...h-rocksdb/src/main/java/com/baidu/hugegraph/backend/store/rocksdb/RocksDBStdSessions.java b/...h-rocksdb/src/main/java/com/baidu/hugegraph/backend/store/rocksdb/RocksDBStdSessions.java
@@ -65,6 +65,7 @@
 import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumn;
 import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumnIterator;
 import com.baidu.hugegraph.backend.store.BackendEntryIterator;
+import com.baidu.hugegraph.config.CoreOptions;
 import com.baidu.hugegraph.config.HugeConfig;
 import com.baidu.hugegraph.util.Bytes;
 import com.baidu.hugegraph.util.E;
@@ -683,11 +684,17 @@ private final class StdSession extends RocksDBSessions.Session {
         private WriteOptions writeOptions;
 
         public StdSession(HugeConfig conf) {
-            boolean bulkload = conf.get(RocksDBOptions.BULKLOAD_MODE);
+            boolean raftMode = conf.get(CoreOptions.RAFT_MODE);
             this.batch = new WriteBatch();
             this.writeOptions = new WriteOptions();
-            this.writeOptions.setDisableWAL(bulkload);
-            //this.writeOptions.setSync(false);
+            /*
+             * When work under raft mode. if store crashed, the state-machine
+             * can restore by snapshot + raft log, doesn't need wal and sync
+             */
+            if (raftMode) {
+                this.writeOptions.setDisableWAL(true);
+                this.writeOptions.setSync(false);
+            }
         }
 
         @Override