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);