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 5108700 commit 6b840f0Copy full SHA for 6b840f0
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("file:" + tempDirName+"/part-00000", new Text(content1).toString());
643
- container.put("file:" + tempDirName+"/part-00001", new Text(content2).toString());
+ container.put(tempDirName+"/part-00000", new Text(content1).toString());
+ container.put(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