Skip to content

Commit 872baa8

Browse files
committed
Adjust configuration with consts
1 parent 48fd172 commit 872baa8

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -275,12 +275,12 @@ void ProductNameTest() throws Exception {
275275
// create sink
276276
ClickHouseAsyncSink<String> csvSink = new ClickHouseAsyncSink<>(
277277
convertorString,
278-
5000,
279-
2,
280-
20000,
281-
1024 * 1024,
282-
5 * 1000,
283-
1000,
278+
MAX_BATCH_SIZE,
279+
MAX_IN_FLIGHT_REQUESTS,
280+
MAX_BUFFERED_REQUESTS,
281+
MAX_BATCH_SIZE_IN_BYTES,
282+
MAX_TIME_IN_BUFFER_MS,
283+
MAX_RECORD_SIZE_IN_BYTES,
284284
clickHouseClientConfig
285285
);
286286
csvSink.setClickHouseFormat(ClickHouseFormat.CSV);
@@ -297,7 +297,7 @@ void ProductNameTest() throws Exception {
297297
"GzipCsvSource"
298298
);
299299
lines.sinkTo(csvSink);
300-
int rows = executeJob(env, tableName);
300+
int rows = executeAsyncJob(env, tableName);
301301
Assertions.assertEquals(EXPECTED_ROWS, rows);
302302
ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
303303
if (ClickHouseServerForTests.isCloud())

0 commit comments

Comments
 (0)