[incubator-iotdb] branch cluster_concurrent updated: Delete raft task manager temporarily

[lta]

This is an automated email from the ASF dual-hosted git repository.

lta pushed a commit to branch cluster_concurrent
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/cluster_concurrent by this 
push:
     new 3019b40  Delete raft task manager temporarily
3019b40 is described below

commit 3019b40dd743d19ae7f272853090c9958af5c698
Author: lta <litiana...@163.com>
AuthorDate: Fri Apr 12 10:53:26 2019 +0800

    Delete raft task manager temporarily
---
 .../apache/iotdb/cluster/entity/raft/DataStateMachine.java  | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
index 3e07aea..3a37a3f 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
@@ -30,7 +30,6 @@ import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicLong;
-import org.apache.iotdb.cluster.concurrent.pool.RaftTaskManager;
 import org.apache.iotdb.cluster.rpc.raft.closure.ResponseClosure;
 import org.apache.iotdb.cluster.rpc.raft.request.DataGroupNonQueryRequest;
 import org.apache.iotdb.cluster.rpc.raft.response.BasicResponse;
@@ -80,12 +79,12 @@ public class DataStateMachine extends StateMachineAdapter {
       final Closure closure = iterator.done();
       final ByteBuffer data = iterator.getData();
 
-      /** It's leader to apply task **/
-      if (closure != null) {
-        RaftTaskManager.getInstance().execute(() -> applySingleTask(closure, 
data));
-      } else {
-        applySingleTask(null, data);
-      }
+//      /** It's leader to apply task **/
+//      if (closure != null) {
+//        RaftTaskManager.getInstance().execute(() -> applySingleTask(closure, 
data));
+//      } else {
+        applySingleTask(closure, data);
+//      }
       iterator.next();
     }
   }