[hotfix][runtime] Remove never thrown IOException for ContinuousFileM…

…onitoringFunction#listEligibleFiles This closes apache#12005
static-max · Sep 4, 2020 · 12b9f7f · 12b9f7f
1 parent 5cce765
commit 12b9f7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java b/...ava/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
@@ -297,7 +297,7 @@ private Map<Long, List<TimestampedFileInputSplit>> getInputSplitsSortedByModTime
  * 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 {