Skip to content

Commit 5086a2e

Browse files
authored
[Bugfix] Don't clear the buffer before flushing when closing for flink-1.13 (StarRocks#264)
Signed-off-by: PengFei Li <[email protected]>
1 parent dfd0e9f commit 5086a2e

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

src/main/java/com/starrocks/connector/flink/manager/StarRocksSinkManager.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,6 @@ public synchronized void close() {
267267
if (!closed) {
268268
closed = true;
269269
LOG.info("StarRocks Sink is about to close, loadMetrics: {}.", metricsToString());
270-
this.bufferMap.clear();
271270
if (scheduledFuture != null) {
272271
scheduledFuture.cancel(false);
273272
scheduler.shutdown();

0 commit comments

Comments
 (0)