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 2016/03/22 12:44:32 UTC
flink git commit: [FLINK-3645] [tests] Force HDFSCopyUtilitiesTest to
use local file system
Repository: flink
Updated Branches:
refs/heads/master ede7fdc4a -> 9c8747d38
[FLINK-3645] [tests] Force HDFSCopyUtilitiesTest to use local file system
This closes #1825.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9c8747d3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9c8747d3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9c8747d3
Branch: refs/heads/master
Commit: 9c8747d38eb593e330d3c310511605109e957b56
Parents: ede7fdc
Author: Chiwan Park <ch...@apache.org>
Authored: Tue Mar 22 17:44:35 2016 +0900
Committer: Chiwan Park <ch...@apache.org>
Committed: Tue Mar 22 20:43:28 2016 +0900
----------------------------------------------------------------------
.../org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9c8747d3/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
index 9022e18..f16750d 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
@@ -62,7 +62,7 @@ public class HDFSCopyUtilitiesTest {
HDFSCopyFromLocal.copyFromLocal(
originalFile,
- new Path(copyFile.getAbsolutePath()).toUri());
+ new Path("file://" + copyFile.getAbsolutePath()).toUri());
try (DataInputStream in = new DataInputStream(new FileInputStream(copyFile))) {
assertTrue(in.readUTF().equals("Hello there, 42!"));
@@ -87,7 +87,7 @@ public class HDFSCopyUtilitiesTest {
}
HDFSCopyToLocal.copyToLocal(
- new Path(originalFile.getAbsolutePath()).toUri(),
+ new Path("file://" + originalFile.getAbsolutePath()).toUri(),
copyFile);
try (DataInputStream in = new DataInputStream(new FileInputStream(copyFile))) {