@@ -187,7 +187,7 @@ public void test_MultithreadedTableWriter_memory_dbname_wrong() throws Exception
187
187
"" , "tt" , false , false , null , 10000 , 1 ,
188
188
5 , "date" );
189
189
}catch (Exception e ) {
190
- assertEquals (HOST +":" +PORT +" Server response: ' Syntax Error: [line #1] Cannot recognize the token tt' script: ' schema(tt)' " ,e .getMessage ());
190
+ assertEquals (HOST +":" +PORT +" Server response: Syntax Error: [line #1] Cannot recognize the token tt. script: schema(tt)" ,e .getMessage ());
191
191
}
192
192
conn .run ("undef(`t1,SHARED)" );
193
193
}
@@ -581,17 +581,17 @@ public void test_MultithreadedTableWriter_threadcount() throws Exception {
581
581
public void test_insert_allnull () throws Exception {
582
582
583
583
StringBuilder sb = new StringBuilder ();
584
- sb .append ("t = table(1000:0, `bool`char`short`lo`date`month`second`datetime`timestamp`nanotime`nanotimestamp`float`double`symbol`string`uuid`ipaddr`int128`int`arrv`blob ," +
585
- "[BOOL,CHAR,SHORT,LONG,DATE,MONTH,SECOND,DATETIME,TIMESTAMP,NANOTIME,NANOTIMESTAMP,FLOAT,DOUBLE,SYMBOL,STRING,UUID, IPADDR, INT128,INT,INT[],BLOB ]);" +
584
+ sb .append ("t = table(1000:0, `bool`char`short`lo`date`month`second`datetime`timestamp`nanotime`nanotimestamp`float`double`symbol`string`uuid`ipaddr`int128`int," +
585
+ "[BOOL,CHAR,SHORT,LONG,DATE,MONTH,SECOND,DATETIME,TIMESTAMP,NANOTIME,NANOTIMESTAMP,FLOAT,DOUBLE,SYMBOL,STRING,UUID, IPADDR, INT128,INT]);" +
586
586
"share t as t1;" );
587
587
conn .run (sb .toString ());
588
588
mutithreadTableWriter_ = new MultithreadedTableWriter (HOST , PORT , "admin" , "123456" ,
589
589
"" , "t1" , false , false , null , 1 , 1 ,
590
590
1 , "bool" );
591
591
592
- ErrorCodeInfo pErrorInfo = mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
593
- mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
594
- mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
592
+ ErrorCodeInfo pErrorInfo = mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
593
+ mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
594
+ mutithreadTableWriter_ .insert ( null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null , null );
595
595
assertEquals ("code= info=" ,pErrorInfo .toString ());
596
596
mutithreadTableWriter_ .waitForThreadCompletion ();
597
597
BasicTable bt = (BasicTable ) conn .run ("select * from t1;" );
0 commit comments