@@ -5102,7 +5102,11 @@ public void test_DBConnection_run_parallelism_1() throws IOException {
51025102 String script2 ="setMaxJobParallelism(\" parallelism_test\" ,22);\n sleep(20);\n getConsoleJobs();" ;
51035103 BasicTable re = (BasicTable )conn .run (script2 ,4 ,5 ,false );
51045104 System .out .println (re .getString ());
5105- Assert .assertEquals ("5" ,re .getColumn (6 ).get (0 ).getString ());
5105+
5106+ DBConnection conn1 = new DBConnection ();
5107+ conn1 .connect (HOST ,PORT ,"parallelism_test" ,"123456" );
5108+ BasicTable re1 = (BasicTable )conn .run ("getConsoleJobs();" ,4 ,5 ,false );
5109+ Assert .assertEquals ("5" ,re1 .getColumn (6 ).get (0 ).getString ());
51065110 }
51075111 @ Test //api设置的parallelism大于server的setMaxJobParallelism
51085112 public void test_DBConnection_run_parallelism_2 () throws IOException {
@@ -5112,7 +5116,6 @@ public void test_DBConnection_run_parallelism_2() throws IOException {
51125116 String script2 ="setMaxJobParallelism(\" parallelism_test\" ,22);\n sleep(100);\n getConsoleJobs();" ;
51135117 BasicTable re = (BasicTable )conn .run (script2 ,5 ,30 ,false );
51145118 System .out .println (re .getColumn (6 ).get (0 ).getString ());
5115- //Assert.assertEquals("22",re.getColumn(6).get(0).getString());
51165119
51175120 DBConnection conn1 = new DBConnection ();
51185121 conn1 .connect (HOST ,PORT ,"parallelism_test" ,"123456" );
0 commit comments