Skip to content

Commit c17bb06

Browse files
committed
Remove join from logic
1 parent 02e4aa7 commit c17bb06

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ protected void submitRequestEntries(List<ClickHousePayload> requestEntries, Resu
102102
}
103103
// send the number that is sent to ClickHouse
104104
this.numRecordsSendCounter.inc(requestEntries.size());
105-
LOG.info("Data that will be send to ClickHouse in bytes {} and the amount of records {}.", numBytesSendCounter.getCount(), requestEntries.size());
105+
LOG.info("Data that will be sent to ClickHouse in bytes {} and the amount of records {}.", numBytesSendCounter.getCount(), requestEntries.size());
106106
out.close();
107107
}, format, new InsertSettings().setOption(ClientConfigProperties.ASYNC_OPERATIONS.getKey(), "true"));
108108
response.whenComplete((insertResponse, throwable) -> {
@@ -111,7 +111,7 @@ protected void submitRequestEntries(List<ClickHousePayload> requestEntries, Resu
111111
} else {
112112
handleSuccessfulRequest(resultHandler, insertResponse);
113113
}
114-
}).join();
114+
});
115115
} catch (Exception e) {
116116
LOG.error("Error: ", e);
117117
}

0 commit comments

Comments
 (0)