@@ -5102,7 +5102,11 @@ public void test_DBConnection_run_parallelism_1() throws IOException {
5102
5102
String script2 ="setMaxJobParallelism(\" parallelism_test\" ,22);\n sleep(20);\n getConsoleJobs();" ;
5103
5103
BasicTable re = (BasicTable )conn .run (script2 ,4 ,5 ,false );
5104
5104
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 ());
5106
5110
}
5107
5111
@ Test //api设置的parallelism大于server的setMaxJobParallelism
5108
5112
public void test_DBConnection_run_parallelism_2 () throws IOException {
@@ -5112,7 +5116,6 @@ public void test_DBConnection_run_parallelism_2() throws IOException {
5112
5116
String script2 ="setMaxJobParallelism(\" parallelism_test\" ,22);\n sleep(100);\n getConsoleJobs();" ;
5113
5117
BasicTable re = (BasicTable )conn .run (script2 ,5 ,30 ,false );
5114
5118
System .out .println (re .getColumn (6 ).get (0 ).getString ());
5115
- //Assert.assertEquals("22",re.getColumn(6).get(0).getString());
5116
5119
5117
5120
DBConnection conn1 = new DBConnection ();
5118
5121
conn1 .connect (HOST ,PORT ,"parallelism_test" ,"123456" );
0 commit comments