@@ -500,7 +500,7 @@ public void test_EventClient_commonKeys_one_column() throws IOException, Interr
500500 Assert .assertEquals (re2 .getColumn (0 ).get (0 ).getString (),re .getColumn (0 ).get (0 ).getString ());
501501 Assert .assertEquals ("00:00:00.001" ,re .getColumn (1 ).get (0 ).getString ());
502502 Assert .assertEquals ("tesrtttt" ,re1 .getColumn (0 ).get (0 ).getString ());
503- Assert .assertEquals (re2 .getColumn (0 ).get (0 ).getString (),re1 .getColumn (1 ).get (0 ).getString ());
503+ Assert .assertEquals (re2 .getColumn (0 ).get (1 ).getString (),re1 .getColumn (1 ).get (0 ).getString ());
504504 client .unsubscribe (HOST , PORT , "intput" , "test1" );
505505 }
506506
@@ -635,7 +635,6 @@ public void test_EventClient_subscribe_tableName_null() throws IOException, Int
635635 public void test_EventClient_subscribe_actionName_exist () throws IOException , InterruptedException {
636636 subscribePrepare ();
637637 conn .run ("share streamTable(1000000:0, `eventType`event`comment1`comment2, [STRING,BLOB,TIME,STRING]) as inputTable1;" );
638- String re = null ;
639638 client .subscribe (HOST , PORT , "inputTable" , "test1" , handler1 , -1 , true , "admin" , "123456" );
640639 client .subscribe (HOST , PORT , "inputTable1" , "test1" , handler1 , -1 , true , "admin" , "123456" );
641640 client .unsubscribe (HOST , PORT , "inputTable" , "test1" );
0 commit comments