commit d2c84d2eb238dffc80d06e2d63a0640acf051729
author WesleyOne <wesleyone666@163.com> Mon Feb 07 13:42:21 2022 +0800
committer GitHub <noreply@github.com> Mon Feb 07 13:42:21 2022 +0800
tree 6fd2000c09f3764371a38bab6e10d986ae645705
parent 64ec0cab0228b1a029a6da7ea2ac3659a37dc392

fix #127 (#128)

rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java

diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java
index 2843abf..61aadd7 100644
--- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java
+++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java
@@ -116,7 +116,7 @@
         LinkedBlockingQueue<FileIterator> iterators = new LinkedBlockingQueue<>(1000);
         File file = getFile(filePath);
         if (!file.exists()) {
-            return null;
+            throw new RuntimeException("filePath not exist.the filePath is "+filePath);
         }
         try {
             if (!file.isDirectory()) {