[flink] Fix flink job for streaming reading exception won't recover (a…

…pache#2762)
lmagic233 · Jan 23, 2024 · 57aaa5a · 57aaa5a
1 parent 898c0ea
commit 57aaa5a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...nk-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java b/...nk-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java
@@ -212,6 +212,7 @@ protected void processDiscoveredSplits(
                 assignSplits();
             } else {
                 LOG.error("Failed to enumerate files", error);
+                throw new RuntimeException(error);
             }
             return;
         }