From 430f79275f7b2bd4028d8008bab9ab0d91bc2784 Mon Sep 17 00:00:00 2001 From: nravi Date: Thu, 8 May 2014 00:00:49 -0700 Subject: [PATCH] Fix for SPARK-1758: failing test org.apache.spark.JavaAPISuite.wholeTextFiles The prefix "file:" is missing in the string inserted as key in HashMap. --- core/src/test/java/org/apache/spark/JavaAPISuite.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/test/java/org/apache/spark/JavaAPISuite.java b/core/src/test/java/org/apache/spark/JavaAPISuite.java index c3e03cea917b..d66d9af43507 100644 --- a/core/src/test/java/org/apache/spark/JavaAPISuite.java +++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java @@ -640,8 +640,8 @@ public void wholeTextFiles() throws IOException { ds.close(); HashMap container = new HashMap(); - container.put(tempDirName+"/part-00000", new Text(content1).toString()); - container.put(tempDirName+"/part-00001", new Text(content2).toString()); + container.put("file:" + tempDirName+"/part-00000", new Text(content1).toString()); + container.put("file:" + tempDirName+"/part-00001", new Text(content2).toString()); JavaPairRDD readRDD = sc.wholeTextFiles(tempDirName, 3); List> result = readRDD.collect();