@@ -500,7 +500,7 @@ public void test_EventClient_commonKeys_one_column() throws IOException, Interr
500
500
Assert .assertEquals (re2 .getColumn (0 ).get (0 ).getString (),re .getColumn (0 ).get (0 ).getString ());
501
501
Assert .assertEquals ("00:00:00.001" ,re .getColumn (1 ).get (0 ).getString ());
502
502
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 ());
504
504
client .unsubscribe (HOST , PORT , "intput" , "test1" );
505
505
}
506
506
@@ -635,7 +635,6 @@ public void test_EventClient_subscribe_tableName_null() throws IOException, Int
635
635
public void test_EventClient_subscribe_actionName_exist () throws IOException , InterruptedException {
636
636
subscribePrepare ();
637
637
conn .run ("share streamTable(1000000:0, `eventType`event`comment1`comment2, [STRING,BLOB,TIME,STRING]) as inputTable1;" );
638
- String re = null ;
639
638
client .subscribe (HOST , PORT , "inputTable" , "test1" , handler1 , -1 , true , "admin" , "123456" );
640
639
client .subscribe (HOST , PORT , "inputTable1" , "test1" , handler1 , -1 , true , "admin" , "123456" );
641
640
client .unsubscribe (HOST , PORT , "inputTable" , "test1" );
0 commit comments