You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/04/22 06:08:29 UTC

[incubator-iotdb] branch cluster_read updated: update remote unit test

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

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


The following commit(s) were added to refs/heads/cluster_read by this push:
     new 7911c87  update remote unit test
7911c87 is described below

commit 7911c870c58b0f9f187d4d26e37429ac6a6cfea3
Author: lta <li...@163.com>
AuthorDate: Mon Apr 22 14:08:11 2019 +0800

    update remote unit test
---
 .../integration/IoTDBMetadataFetchRemoteIT.java    | 70 +++++++++++-----------
 1 file changed, 35 insertions(+), 35 deletions(-)

diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchRemoteIT.java b/cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchRemoteIT.java
index ccb1456..d973273 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchRemoteIT.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBMetadataFetchRemoteIT.java
@@ -30,41 +30,41 @@ import org.junit.BeforeClass;
 import org.junit.Test;
 
 public class IoTDBMetadataFetchRemoteIT extends IoTDBMetadataFetchAbstract{
-  @BeforeClass
-  public static void  setUp() throws Exception {
-    Class.forName(Config.JDBC_DRIVER_NAME);
-    ClusterConfigureGenerator.generateClusterConfigure();
-  }
-
-  @AfterClass
-  public static void tearDown() throws Exception {
-    ClusterConfigureGenerator.deleteClusterConfigure();
-  }
-
-  @Test
-  public void test() throws IOException {
-    String dir = Utils.getCurrentPath("pwd");
-//    startScript("sh", dir + File.separator + "script" + File.separator + "deploy.sh", "7", "1", dir);
-    startScript("sh", dir + File.separator + "script" + File.separator + "stop.sh", "7", "3", dir);
-  }
-
-  private void startScript(String... command) throws IOException{
-    ProcessBuilder builder = new ProcessBuilder(command);
-    builder.redirectErrorStream(true);
-    Process p = builder.start();
-    BufferedReader r = new BufferedReader(new InputStreamReader(p.getInputStream()));
-    String line;
-    while (true) {
-      line = r.readLine();
-      if (line == null) {
-        break;
-      } else {
-        System.out.println(line);
-      }
-    }
-    r.close();
-    p.destroy();
-  }
+//  @BeforeClass
+//  public static void  setUp() throws Exception {
+//    Class.forName(Config.JDBC_DRIVER_NAME);
+//    ClusterConfigureGenerator.generateClusterConfigure();
+//  }
+//
+//  @AfterClass
+//  public static void tearDown() throws Exception {
+//    ClusterConfigureGenerator.deleteClusterConfigure();
+//  }
+//
+//  @Test
+//  public void test() throws IOException {
+//    String dir = Utils.getCurrentPath("pwd");
+////    startScript("sh", dir + File.separator + "script" + File.separator + "deploy.sh", "7", "1", dir);
+//    startScript("sh", dir + File.separator + "script" + File.separator + "stop.sh", "7", "3", dir);
+//  }
+//
+//  private void startScript(String... command) throws IOException{
+//    ProcessBuilder builder = new ProcessBuilder(command);
+//    builder.redirectErrorStream(true);
+//    Process p = builder.start();
+//    BufferedReader r = new BufferedReader(new InputStreamReader(p.getInputStream()));
+//    String line;
+//    while (true) {
+//      line = r.readLine();
+//      if (line == null) {
+//        break;
+//      } else {
+//        System.out.println(line);
+//      }
+//    }
+//    r.close();
+//    p.destroy();
+//  }
 
 
 }