@@ -1561,7 +1561,9 @@ public void testQueryParams() throws Exception {
15611561 public void testExecuteQueryParam () throws ExecutionException , InterruptedException , TimeoutException {
15621562
15631563 final String table = "execute_query_test" ;
1564- Map <String , Object > query_param = Map .of ("table_name" ,table , "engine" ,"MergeTree" );
1564+ Map <String , Object > query_param = new HashMap <>();
1565+ query_param .put ("table_name" ,table );
1566+ query_param .put ("engine" ,"MergeTree" );
15651567 client .execute ("DROP TABLE IF EXISTS " + table ).get (10 , TimeUnit .SECONDS );
15661568 client .execute ("CREATE TABLE {table_name:Identifier} ( id UInt32, name String, created_at DateTime) ENGINE = MergeTree ORDER BY tuple()" , query_param )
15671569 .get (10 , TimeUnit .SECONDS );
@@ -1575,7 +1577,9 @@ public void testExecuteQueryParamCommandSettings() throws ExecutionException, In
15751577
15761578 final String table = "execute_query_test" ;
15771579 String q1Id = UUID .randomUUID ().toString ();
1578- Map <String , Object > query_param = Map .of ("table_name" ,table , "engine" ,"MergeTree" );
1580+ Map <String , Object > query_param = new HashMap <>();
1581+ query_param .put ("table_name" ,table );
1582+ query_param .put ("engine" ,"MergeTree" );
15791583 client .execute ("DROP TABLE IF EXISTS " + table ).get (10 , TimeUnit .SECONDS );
15801584 client .execute ("CREATE TABLE {table_name:Identifier} ( id UInt32, name String, created_at DateTime) ENGINE = MergeTree ORDER BY tuple()" ,
15811585 query_param , (CommandSettings ) new CommandSettings ().setQueryId (q1Id ))
0 commit comments