(incubator-paimon) branch master updated: [flink] Fix flink job for streaming reading exception won't recover (#2762)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 57aaa5a8c [flink] Fix flink job for streaming reading exception won't 
recover (#2762)
57aaa5a8c is described below

commit 57aaa5a8c526a3d619c2ac59b31bb5d69ebc7f97
Author: Jiangqiao Xu <96433131+bridgedr...@users.noreply.github.com>
AuthorDate: Tue Jan 23 14:43:16 2024 +0800

    [flink] Fix flink job for streaming reading exception won't recover (#2762)
---
 .../org/apache/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 e15d8ddf4..9096f2814 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 @@ public class ContinuousFileSplitEnumerator
                 assignSplits();
             } else {
                 LOG.error("Failed to enumerate files", error);
+                throw new RuntimeException(error);
             }
             return;
         }