[iotdb] 01/01: recursive

[yuyuankang]

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

yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 904026a796dbcede9e0d512d76fc487bebe09c53
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Sun Oct 4 10:47:52 2020 +0800

    recursive
---
 .../cluster/server/member/MetaGroupMember.java     | 10 +--------
 .../main/java/org/apache/iotdb/SessionExample.java | 26 ++++++++++++----------
 2 files changed, 15 insertions(+), 21 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
index 19b45b3..5012510 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
@@ -1137,15 +1137,7 @@ public class MetaGroupMember extends RaftMember {
             size, readCnt));
       }
 
-      partitionTable = new SlotPartitionTable(thisNode);
-      partitionTable.deserialize(ByteBuffer.wrap(tableBuffer));
-      allNodes = new ArrayList<>(partitionTable.getAllNodes());
-      initPeerMap();
-      for (Node node : allNodes) {
-        idNodeMap.put(node.getNodeIdentifier(), node);
-      }
-      router = new ClusterPlanRouter(partitionTable);
-      startSubServers();
+      acceptPartitionTable(ByteBuffer.wrap(tableBuffer));
 
       logger.info("Load {} nodes: {}", allNodes.size(), allNodes);
     } catch (IOException e) {
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java 
b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 0534683..bebd0ca 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -42,7 +42,7 @@ public class SessionExample {
 
   public static void main(String[] args)
       throws IoTDBConnectionException, StatementExecutionException {
-    session = new Session("127.0.0.1", 6667, "root", "root");
+    session = new Session("127.0.0.1", 55560, "root", "root");
     session.open(false);
 
     try {
@@ -52,18 +52,20 @@ public class SessionExample {
         throw e;
     }
 
-    createTimeseries();
+//    createTimeseries();
+    System.out.println("start create timeseries ");
     createMultiTimeseries();
-    insertRecord();
-    insertTablet();
-    insertTablets();
-    insertRecords();
-    nonQuery();
-    query();
-    rawDataQuery();
-    queryByIterator();
-    deleteData();
-    deleteTimeseries();
+    System.out.println("end create timeseries");
+//    insertRecord();
+//    insertTablet();
+//    insertTablets();
+//    insertRecords();
+//    nonQuery();
+//    query();
+//    rawDataQuery();
+//    queryByIterator();
+//    deleteData();
+//    deleteTimeseries();
     session.close();
   }