fix broken case

Author: weisun123

test/com/xxdb/MultithreadedTableWriterTest.java

@@ -11,6 +11,7 @@
 import junit.framework.Assert;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.BeforeClass;
 import org.junit.Test;
 
 import java.io.ByteArrayOutputStream;
@@ -45,7 +46,13 @@ public  class MultithreadedTableWriterTest implements Runnable {
 
     public MultithreadedTableWriterTest() {
     }
-
+    @BeforeClass
+    public static void prepare1 () throws IOException {
+        DBConnection controller_conn = new DBConnection();
+        controller_conn.connect(CONTROLLER_HOST, CONTROLLER_PORT, "admin", "123456");
+        controller_conn.run("try{startDataNode('" + HOST + ":" + PORT + "')}catch(ex){}");
+        controller_conn.run("sleep(5000)");
+    }
     @Before
     public void prepare() throws IOException {
         conn = new DBConnection(false,false,true);

test/com/xxdb/SimpleDBConnectionPoolTest.java

@@ -529,7 +529,7 @@ public void test_SimpleDBConnectionPool_config_HighAvailability_true_LoadBalance
         DBConnection poolEntity = pool.getConnection();
         controller_conn.run("try{startDataNode('"+HOST+":"+PORT+"')}catch(ex){}");
         int port1 = port_list[1];
-        poolEntity.run("sleep(2000)");
+        //poolEntity.run("sleep(2000)");
         BasicTable re = (BasicTable) poolEntity.run("select port ,connectionNum  from rpc(getControllerAlias(),getClusterPerf) where mode= 0");
         for (int i = 0; i < re.rows(); i++) {
             System.out.println("port:" + re.getColumn(0).get(i) + " connectionNum:" + re.getColumn(1).get(i));

test/com/xxdb/streaming/reverse/PollingClientReverseTest.java

@@ -527,7 +527,7 @@ public void test_subscribe_offset_reconnect() throws IOException {
 //                }
 
             }
-            pollingClient1.unsubscribe(HOST, PORT, "Trades1");
+            pollingClient.unsubscribe(HOST, PORT, "Trades1");
 //            pollingClient.unsubscribe(HOST, PORT, "Trades1");
         }
     }

test/com/xxdb/streaming/reverse/ThreadedClientsubscribeReverseTest.java

@@ -500,7 +500,7 @@ public void test_subscribe_TableName_ActionName_Handler_reconnect() throws IOExc
         write_data.start();
         Thread.sleep(1000);
         conn.run("stopPublishTable('"+HOST+"',9055,'Trades',\"subTrades\")");
-        Thread.sleep(1000);
+        Thread.sleep(2000);
         //conn.run("stopPublishTable('"+HOST+"',9055,'Trades',\"subTrades\")");
         //Thread.sleep(3000);
         BasicInt row_num = (BasicInt)conn.run("(exec count(*) from Receive)[0]");