update test case about prepare

Author: weisun123

test/com/xxdb/LoadBalanceTest.java

@@ -614,7 +614,7 @@ public void run() {
         MyThread thread = new MyThread();
         MyThread1 thread1 = new MyThread1();
         thread.start();
-        Thread.sleep(15);
+        Thread.sleep(20);
         System.err.println("thread1开始运行 ");
         thread1.start();
         thread.join();

test/com/xxdb/Prepare.java

@@ -14,9 +14,8 @@ public class Prepare {
     static int[] port_list = Arrays.stream(bundle.getString("PORTS").split(",")).mapToInt(Integer::parseInt).toArray();
 
     public static void clear_env() throws IOException {
-        for (int i = 0; i < port_list.length; i++) {
             DBConnection conn = new DBConnection();
-            conn.connect(HOST, port_list[i], "admin", "123456");
+            conn.connect(HOST, PORT, "admin", "123456");
             conn.run("a = getStreamingStat().pubTables\n" +
                     "for(i in a){\n" +
                     "\ttry{stopPublishTable(i.subscriber.split(\":\")[0],int(i.subscriber.split(\":\")[1]),i.tableName,i.actions)}catch(ex){}\n" +
@@ -40,7 +39,6 @@ public static void clear_env() throws IOException {
                     "}\n" +
                     "clearShare()");
             conn.run("try{dropStreamEngine(\"serInput\");\n}catch(ex){\n}\n");
-        }
     }
 
     public static void Preparedata(long count) throws IOException {

test/com/xxdb/streaming/client/cep/EventClientTest.java

@@ -924,7 +924,7 @@ public  void test_EventClient_subscribe_haStreamTable() throws IOException, Inte
         BasicTable re = (BasicTable)conn.run("select * from outputTable");
         Assert.assertEquals(1,re.rows());
     }
-    @Test
+    //@Test
     public  void test_EventClient_subscribe_haStreamTable_leader() throws IOException, InterruptedException {
         BasicString StreamLeaderTmp = (BasicString)conn.run(String.format("getStreamingLeader(%d)", GROUP_ID));
         String StreamLeader = StreamLeaderTmp.getString();