update test case about stream

Author: weisun123

test/com/xxdb/Prepare.java

@@ -253,7 +253,7 @@ public static void PrepareStreamTable_array(String dataType) throws IOException
                 "dateType_COMPLEX =   array(COMPLEX[]).append!(cut(rand(complex(rand(100, 1000), rand(100, 1000)) join NULL, 1000*10), 10));; \n"+
                 "dateType_POINT =  array(POINT[]).append!(cut(rand(point(rand(100, 1000), rand(100, 1000)) join NULL, 1000*10), 10)); \n"+
                 "share table(permno,dateType_"+dataType +") as pub_t\n"+
-                "share streamTable(1000000:0, `permno`dateType, [INT,"+dataType +"[]]) as sub1;\n";
+                "share streamTable(10000:0, `permno`dateType, [INT,"+dataType +"[]]) as sub1;\n";
         DBConnection conn1 = new DBConnection();
         conn1.connect(HOST, PORT,"admin","123456");
         conn1.run(script);
@@ -265,7 +265,7 @@ public static void PrepareStreamTableDecimal_array(String dataType, int scale) t
                 "dateType_DECIMAL64 =   array(DECIMAL64(4)[]).append!(cut(decimal32(take(-100..100 join NULL, 1000*10) + 0.254, 3), 10)); \n"+
                 "dateType_DECIMAL128 =   array(DECIMAL128(8)[]).append!(cut(decimal32(take(-100..100 join NULL, 1000*10) + 0.254, 3), 10)); \n"+
                 "share table(permno,dateType_"+dataType +") as pub_t\n"+
-                "share streamTable(1000000:0, `permno`dateType, [INT,"+dataType +"("+scale+")[]]) as sub1;\n";
+                "share streamTable(10000:0, `permno`dateType, [INT,"+dataType +"("+scale+")[]]) as sub1;\n";
         DBConnection conn1 = new DBConnection();
         conn1.connect(HOST, PORT,"admin","123456");
         conn1.run(script);
@@ -288,7 +288,7 @@ public static void wait_data(String table_name, int data_row) throws IOException
         DBConnection conn = new DBConnection();
         conn.connect(HOST,PORT,"admin","123456");
         BasicInt row_num;
-        for(int i=0;i<50;i++){
+        for(int i=0;i<200;i++){
             row_num = (BasicInt)conn.run("(exec count(*) from "+table_name+")[0]");
 //            System.out.println(row_num.getInt());
             if(row_num.getInt() == data_row){