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 <felixzhen...@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 {
