You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/09/04 15:49:51 UTC
[flink] 01/04: [hotfix][runtime] Remove never thrown IOException
for ContinuousFileMonitoringFunction#listEligibleFiles
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 12b9f7f785995f1c3bbbffe3e7a99f39703acf3f
Author: felixzheng <fe...@gmail.com>
AuthorDate: Wed May 6 17:54:57 2020 +0800
[hotfix][runtime] Remove never thrown IOException for ContinuousFileMonitoringFunction#listEligibleFiles
This closes #12005
---
.../api/functions/source/ContinuousFileMonitoringFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
index f73c23d..c6de6f1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
@@ -297,7 +297,7 @@ public class ContinuousFileMonitoringFunction<OUT>
* Returns the paths of the files not yet processed.
* @param fileSystem The filesystem where the monitored directory resides.
*/
- private Map<Path, FileStatus> listEligibleFiles(FileSystem fileSystem, Path path) throws IOException {
+ private Map<Path, FileStatus> listEligibleFiles(FileSystem fileSystem, Path path) {
final FileStatus[] statuses;
try {