From 0d0dc6fb07e0c5496224c75052ab4f43d57b40f6 Mon Sep 17 00:00:00 2001
From: Vinay Patil <52563354+veenaypatil@users.noreply.github.com>
Date: Mon, 7 Jun 2021 19:28:19 +0530
Subject: [PATCH] [HUDI-1909] Skip Commits with empty files (#3045)

---
 .../org/apache/hudi/source/StreamReadMonitoringFunction.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java b/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
index b6eb39754..3a2de84bb 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
@@ -225,7 +225,8 @@ public class StreamReadMonitoringFunction
     Set<String> writePartitions = getWritePartitionPaths(metadataList);
     FileStatus[] fileStatuses = getWritePathsOfInstants(metadataList);
     if (fileStatuses.length == 0) {
-      throw new HoodieException("No files found for reading in user provided path.");
+      LOG.warn("No files found for reading in user provided path.");
+      return;
     }
 
     HoodieTableFileSystemView fsView = new HoodieTableFileSystemView(metaClient, commitTimeline, fileStatuses);