Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
2.0.0
-
None
Description
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.
Attachments
Issue Links
- is related to
-
SPARK-16613 RDD.pipe returns values for empty partitions
- Resolved
- links to