-
Type:
Bug
-
Status: Resolved
-
Priority:
Blocker
-
Resolution: Fixed
-
Affects Version/s: 2.0.0
-
Fix Version/s: 2.0.0
-
Component/s: Spark Core
-
Labels:None
-
Target Version/s:
Currently RDD.pipe(command: String):
- works only when the command is specified without any options, such as RDD.pipe("wc")
- does NOT work when the command is specified with some options, such as RDD.pipe("wc -l")
This is a regression from Spark 1.6.
- is related to
-
SPARK-16613 RDD.pipe returns values for empty partitions
-
- Resolved
-
- links to