Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
BoundedDataset#action does not materialize RDD since it uses foreachPartition which is not an action, instead use foreach which is.
The reason it worked until now was because there was also a call to cache() before it.
http://spark.apache.org/docs/1.6.3/programming-guide.html#actions
Attachments
Issue Links
- links to