Skip to content

Commit ed92b0a

Browse files
committed
Remove System.out
1 parent 94a85db commit ed92b0a

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

flink-connector-clickhouse-base/src/main/java/org/apache/flink/connector/clickhouse/sink/ClickHouseAsyncWriter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,6 @@ protected long getSizeInBytes(ClickHousePayload clickHousePayload) {
6060
@Override
6161
protected void submitRequestEntries(List<ClickHousePayload> requestEntries, ResultHandler<ClickHousePayload> resultHandler) {
6262
LOG.info("Submitting request entries...");
63-
System.out.println("Submitting request entries...");
6463
AtomicInteger totalSizeSend = new AtomicInteger();
6564
Client chClient = this.clickHouseClientConfig.createClient();
6665
String tableName = clickHouseClientConfig.getTableName();

0 commit comments

Comments
 (0)