[incubator-iotdb] branch cluster updated: fix a bug in class DataStateMachine

[lta]

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

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


The following commit(s) were added to refs/heads/cluster by this push:
     new 8b37fe5  fix a bug in class DataStateMachine
8b37fe5 is described below

commit 8b37fe55d281673ff5fad8c9715475441fd847e0
Author: lta <litiana...@163.com>
AuthorDate: Sun Mar 31 22:20:22 2019 +0800

    fix a bug in class DataStateMachine
---
 .../java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java  | 5 +++--
 .../iotdb/cluster/rpc/processor/DataNonQueryAsyncProcessor.java      | 2 +-
 2 files changed, 4 insertions(+), 3 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 36535d6..ff26108 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,6 +30,7 @@ import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicLong;
+import org.apache.iotdb.cluster.rpc.request.DataNonQueryRequest;
 import org.apache.iotdb.cluster.rpc.request.MetadataNonQueryRequest;
 import org.apache.iotdb.cluster.utils.RaftUtils;
 import org.apache.iotdb.db.exception.PathErrorException;
@@ -61,14 +62,14 @@ public class DataStateMachine extends StateMachineAdapter {
     while (iterator.hasNext()) {
 
       Closure closure = null;
-      MetadataNonQueryRequest request = null;
+      DataNonQueryRequest request = null;
       if (iterator.done() != null) {
         closure = iterator.done();
       }
       final ByteBuffer data = iterator.getData();
       try {
         request = SerializerManager.getSerializer(SerializerManager.Hessian2)
-            .deserialize(data.array(), 
MetadataNonQueryRequest.class.getName());
+            .deserialize(data.array(), DataNonQueryRequest.class.getName());
       } catch (final CodecException e) {
         LOGGER.error("Fail to decode IncrementAndGetRequest", e);
       }
diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/DataNonQueryAsyncProcessor.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/DataNonQueryAsyncProcessor.java
index db734f4..f0134f1 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/DataNonQueryAsyncProcessor.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/DataNonQueryAsyncProcessor.java
@@ -95,6 +95,6 @@ public class DataNonQueryAsyncProcessor extends 
BasicAsyncUserProcessor<DataNonQ
 
   @Override
   public String interest() {
-    return MetadataNonQueryRequest.class.getName();
+    return DataNonQueryRequest.class.getName();
   }
 }