From 57aaa5a8c526a3d619c2ac59b31bb5d69ebc7f97 Mon Sep 17 00:00:00 2001
From: Jiangqiao Xu <96433131+bridgeDream@users.noreply.github.com>
Date: Tue, 23 Jan 2024 14:43:16 +0800
Subject: [PATCH] [flink] Fix flink job for streaming reading exception won't
 recover (#2762)

---
 .../paimon/flink/source/ContinuousFileSplitEnumerator.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java
index e15d8ddf487d..9096f2814825 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java
+++ b/paimon-flink/paimon-flink-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;
         }