From bda3589004234d6040beb9306d38e0e3dff6f606 Mon Sep 17 00:00:00 2001
From: Hongshun Wang <125648852+loserwang1024@users.noreply.github.com>
Date: Fri, 17 Jan 2025 16:20:21 +0800
Subject: [PATCH] [hotfix][connector/flink] Fix Flink sink not stop when
 exception is occurs. (#303)

---
 .../alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java
index 309e199be..32aa67efc 100644
--- a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/sink/FlinkSinkFunction.java
+++ b/fluss-connectors/fluss-connector-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;