@@ -236,7 +236,6 @@ public void testInsertingPOJOWithNullValueForNonNullableColumn() throws Exceptio
236236 try (InsertResponse response = client .insert (tableName , Collections .singletonList (pojo ), settings ).get (30 , TimeUnit .SECONDS )) {
237237 fail ("Should have thrown an exception" );
238238 } catch (ClickHouseException e ) {
239- e .printStackTrace ();
240239 assertTrue (e .getCause () instanceof IllegalArgumentException );
241240 }
242241 }
@@ -291,7 +290,7 @@ public void insertRawDataAsync(boolean async) throws Exception {
291290 assertTrue (Thread .currentThread ().getName ()
292291 .startsWith (async ? "pool-" : "main" ), "Threads starts with " + Thread .currentThread ().getName ());
293292 })
294- .join (); // wait operation complete. only for tests
293+ .join (). close (); // wait operation complete. only for tests
295294 }
296295
297296 @ DataProvider
@@ -662,14 +661,10 @@ public void testCollectionInsert() throws Exception {
662661 out .write (row .getBytes ());
663662 }
664663 }, ClickHouseFormat .JSONEachRow , new InsertSettings ()).get ()) {
665- System .out .println ("Rows written: " + response .getWrittenRows ());
666664 }
667665
668666 List <GenericRecord > records = client .queryAll ("SELECT * FROM \" " + tableName + "\" " );
669-
670- for (GenericRecord record : records ) {
671- System .out .println ("> " + record .getString (1 ) + ", " + record .getFloat (2 ) + ", " + record .getFloat (3 ));
672- }
667+ assertEquals (records .size (), 4 );
673668 }
674669
675670// static {
0 commit comments