[rocketmq-streams] branch main updated: fix #127 (#128)

[duhengforever]

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

duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new d2c84d2  fix #127 (#128)
d2c84d2 is described below

commit d2c84d2eb238dffc80d06e2d63a0640acf051729
Author: WesleyOne <wesleyone...@163.com>
AuthorDate: Mon Feb 7 13:42:21 2022 +0800

    fix #127 (#128)
---
 .../apache/rocketmq/streams/common/channel/impl/file/FileSource.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 @@ public class FileSource extends AbstractBatchSource {
         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()) {