fix bug

JNSimba · Apr 2, 2024 · e4e3173 · e4e3173
1 parent 6ad6b2a
commit e4e3173
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
@@ -292,6 +292,8 @@ public Collection<DorisCommittable> prepareCommit() throws IOException, Interrup
                                                         dorisStreamLoad.getHostPort(),
                                                         dorisStreamLoad.getDb(),
                                                         txnId));
+                                    } else {
+                                        respFuture.complete(null);
                                     }
                                 } catch (Throwable e) {
                                     respFuture.completeExceptionally(e);
@@ -302,7 +304,10 @@ public Collection<DorisCommittable> prepareCommit() throws IOException, Interrup
 
         for (CompletableFuture<DorisCommittable> committableFuture : committableFutures) {
             try {
-                committableList.add(committableFuture.get());
+                DorisCommittable committable = committableFuture.get();
+                if (committable != null) {
+                    committableList.add(committable);
+                }
             } catch (ExecutionException e) {
                 throw new RuntimeException(e);
             }