flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chiwanp...@apache.org
Subject flink git commit: [FLINK-3645] [tests] Force HDFSCopyUtilitiesTest to use local file system
Date Tue, 22 Mar 2016 11:44:32 GMT
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 <chiwanpark@apache.org>
Authored: Tue Mar 22 17:44:35 2016 +0900
Committer: Chiwan Park <chiwanpark@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))) {


Mime
View raw message