(incubator-paimon) branch master updated: [flink] Throw exception when failed to enumerator the splits (#2882)

[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 086de8f60 [flink] Throw exception when failed to enumerator the splits 
(#2882)
086de8f60 is described below

commit 086de8f600919192c2901d1295739900dbb4227d
Author: Aitozi <1059789...@qq.com>
AuthorDate: Wed Feb 21 17:23:23 2024 +0800

    [flink] Throw exception when failed to enumerator the splits (#2882)
---
 .../paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java
index 87ae88a79..e3e0aabb6 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java
@@ -228,6 +228,7 @@ public class AlignedContinuousFileSplitEnumerator extends 
ContinuousFileSplitEnu
                 finished = true;
             } else {
                 LOG.error("Failed to enumerate files", error);
+                throw new RuntimeException(error);
             }
         }