We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b1feb60 commit 681b36fCopy full SHA for 681b36f
core/src/test/java/org/apache/spark/JavaAPISuite.java
@@ -639,8 +639,8 @@ public void wholeTextFiles() throws IOException {
639
ds.close();
640
641
HashMap<String, String> container = new HashMap<String, String>();
642
- container.put(tempDirName+"/part-00000", new Text(content1).toString());
643
- 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());
644
645
JavaPairRDD<String, String> readRDD = sc.wholeTextFiles(tempDirName, 3);
646
List<Tuple2<String, String>> result = readRDD.collect();
0 commit comments