You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/01/05 12:55:33 UTC
[2/5] flink git commit: [FLINK-4870] Fix path handling in
ContinuousFileMonitoringFunction
[FLINK-4870] Fix path handling in ContinuousFileMonitoringFunction
This closes #2887.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed83b5b8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ed83b5b8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ed83b5b8
Branch: refs/heads/master
Commit: ed83b5b89c61cac5d49e690279dab0ea94c35bb3
Parents: 4415dfb
Author: zentol <ch...@apache.org>
Authored: Fri Nov 25 13:27:43 2016 +0100
Committer: zentol <ch...@apache.org>
Committed: Thu Jan 5 12:28:18 2017 +0100
----------------------------------------------------------------------
.../api/functions/source/ContinuousFileMonitoringFunction.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ed83b5b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
----------------------------------------------------------------------
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 1ec9a70..e0a042a 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
@@ -38,7 +38,6 @@ import org.slf4j.LoggerFactory;
import java.io.FileNotFoundException;
import java.io.IOException;
-import java.net.URI;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
@@ -187,8 +186,9 @@ public class ContinuousFileMonitoringFunction<OUT>
@Override
public void run(SourceFunction.SourceContext<TimestampedFileInputSplit> context) throws Exception {
- FileSystem fileSystem = FileSystem.get(new URI(path));
- if (!fileSystem.exists(new Path(path))) {
+ Path p = new Path(path);
+ FileSystem fileSystem = FileSystem.get(p.toUri());
+ if (!fileSystem.exists(p)) {
throw new FileNotFoundException("The provided file path " + path + " does not exist.");
}