Skip to content

Commit 5da6ce6

Browse files
committed
add wait_async_insert
1 parent 967ab47 commit 5da6ce6

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

client-v2/src/test/java/com/clickhouse/client/insert/InsertTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ protected Client.Builder newClient() {
8989
.compressClientRequest(useClientCompression)
9090
.useHttpCompression(useHttpCompression)
9191
.setDefaultDatabase(ClickHouseServerForTest.getDatabase())
92-
.serverSetting(ServerSettings.WAIT_END_OF_QUERY, "1")
92+
.serverSetting(ServerSettings.WAIT_ASYNC_INSERT, "1")
9393
.useNewImplementation(System.getProperty("client.tests.useNewImplementation", "true").equals("true"));
9494
}
9595

jdbc-v2/src/test/java/com/clickhouse/jdbc/JdbcIntegrationTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import com.clickhouse.client.BaseIntegrationTest;
66
import com.clickhouse.client.ClickHouseProtocol;
77
import com.clickhouse.client.api.ClientConfigProperties;
8+
import com.clickhouse.client.api.internal.ServerSettings;
89
import com.clickhouse.client.api.query.GenericRecord;
910
import com.clickhouse.logging.Logger;
1011
import com.clickhouse.logging.LoggerFactory;
@@ -33,7 +34,7 @@ public Connection getJdbcConnection(Properties properties) throws SQLException {
3334
Properties info = new Properties();
3435
info.setProperty("user", "default");
3536
info.setProperty("password", ClickHouseServerForTest.getPassword());
36-
37+
info.setProperty(ServerSettings.WAIT_ASYNC_INSERT, "1");
3738
if (properties != null) {
3839
info.putAll(properties);
3940
}

0 commit comments

Comments
 (0)