[hotfix][connector/flink] Fix Flink sink not stop when exception is o…

…ccurs. (#303)
alibaba · Jan 17, 2025 · bda3589 · bda3589
1 parent 052492f
commit bda3589
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nnector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java b/...nnector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java
@@ -134,7 +134,7 @@ public void invoke(RowData value, SinkFunction.Context context) throws IOExcepti
         CompletableFuture<Void> writeFuture = writeRow(value.getRowKind(), internalRow);
         writeFuture.exceptionally(
                 exception -> {
-                    if (this.asyncWriterException != null) {
+                    if (this.asyncWriterException == null) {
                         this.asyncWriterException = exception;
                     }
                     return null;