fixed async test

chernser · chernser · commit 5892ceb80f31 · 2025-09-25T08:30:55.000-07:00
diff --git a/client-v2/src/test/java/com/clickhouse/client/insert/InsertTests.java b/client-v2/src/test/java/com/clickhouse/client/insert/InsertTests.java
@@ -289,7 +289,7 @@ public void insertRawDataAsync(boolean async) throws Exception {
                 List<GenericRecord> records = client.queryAll("SELECT * FROM " + tableName);
                 assertEquals(records.size(), 1000);
                 assertTrue(Thread.currentThread().getName()
-                        .startsWith(async ? "pool-1-thread-" : "main"), "Threads starts with " + Thread.currentThread().getName());
+                        .startsWith(async ? "pool-" : "main"), "Threads starts with " + Thread.currentThread().getName());
         })
                 .join(); // wait operation complete. only for tests
     }

Original file line number	Diff line number	Diff line change
`@@ -289,7 +289,7 @@ public void insertRawDataAsync(boolean async) throws Exception {`
`289`	`289`	`List<GenericRecord> records = client.queryAll("SELECT * FROM " + tableName);`
`290`	`290`	`assertEquals(records.size(), 1000);`
`291`	`291`	`assertTrue(Thread.currentThread().getName()`
`292`		`- .startsWith(async ? "pool-1-thread-" : "main"), "Threads starts with " + Thread.currentThread().getName());`
	`292`	`+ .startsWith(async ? "pool-" : "main"), "Threads starts with " + Thread.currentThread().getName());`
`293`	`293`	`})`
`294`	`294`	`.join(); // wait operation complete. only for tests`
`295`	`295`	`}`