[incubator-iotdb] branch cluster_concurrent updated: fix ut test of ClusterDescriptorTest

[lt...@apache.org]

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 5113831  fix ut test of ClusterDescriptorTest
5113831 is described below

commit 5113831dd5d0fa1b6be2c0f064f33e69d20a6016
Author: lta <li...@163.com>
AuthorDate: Thu Apr 11 16:38:40 2019 +0800

    fix ut test of ClusterDescriptorTest
---
 .../org/apache/iotdb/cluster/config/ClusterDescriptorTest.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/config/ClusterDescriptorTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/config/ClusterDescriptorTest.java
index 654c172..f2e8a0a 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/config/ClusterDescriptorTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/config/ClusterDescriptorTest.java
@@ -101,7 +101,7 @@ public class ClusterDescriptorTest {
       put("max_queue_num_of_inner_rpc_client", testQueueLenNew);
       put("read_metadata_consistency_level", testMetadataConsistencyNew);
       put("read_data_consistency_level", testDataConsistencyNew);
-      put("concurrent_qp_task_thread", testConcurrentQPTaskThreadNew);
+      put("concurrent_qp_sub_task_thread", testConcurrentQPTaskThreadNew);
       put("concurrent_raft_task_thread", testConcurrentRaftTaskThreadNew);
     }
   };
@@ -147,7 +147,7 @@ public class ClusterDescriptorTest {
     assertEquals(testQueueLenNew, config.getMaxQueueNumOfInnerRpcClient() + "");
     assertEquals(testMetadataConsistencyNew, config.getReadMetadataConsistencyLevel() + "");
     assertEquals(testDataConsistencyNew, config.getReadDataConsistencyLevel() + "");
-    assertEquals(testConcurrentQPTaskThreadNew, config.getConcurrentQPTaskThread() + "");
+    assertEquals(testConcurrentQPTaskThreadNew, config.getConcurrentQPSubTaskThread() + "");
     assertEquals(testConcurrentRaftTaskThreadNew, config.getConcurrentRaftTaskThread() + "");
 
 
@@ -200,7 +200,7 @@ public class ClusterDescriptorTest {
     testQueueLenOld = config.getMaxQueueNumOfInnerRpcClient();
     testMetadataConsistencyOld = config.getReadMetadataConsistencyLevel();
     testDataConsistencyOld = config.getReadDataConsistencyLevel();
-    testConcurrentQPTaskThreadOld = config.getConcurrentQPTaskThread();
+    testConcurrentQPTaskThreadOld = config.getConcurrentQPSubTaskThread();
     testConcurrentRaftTaskThreadOld = config.getConcurrentRaftTaskThread();
   }
 
@@ -224,7 +224,7 @@ public class ClusterDescriptorTest {
     config.setMaxQueueNumOfInnerRpcClient(testQueueLenOld);
     config.setReadMetadataConsistencyLevel(testMetadataConsistencyOld);
     config.setReadDataConsistencyLevel(testDataConsistencyOld);
-    config.setConcurrentQPTaskThread(testConcurrentQPTaskThreadOld);
+    config.setConcurrentQPSubTaskThread(testConcurrentQPTaskThreadOld);
     config.setConcurrentRaftTaskThread(testConcurrentRaftTaskThreadOld);
   }
 }