[
https://issues.apache.org/jira/browse/SPARK-28854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915162#comment-16915162
]
Hao Yang Ang commented on SPARK-28854:
--
[~hyukjin.kwon] got it, my bad.
> Zipping iterators in
[
https://issues.apache.org/jira/browse/SPARK-28854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914981#comment-16914981
]
Hao Yang Ang commented on SPARK-28854:
--
[~hyukjin.kwon] if xs is "consumed" at the first map then
[
https://issues.apache.org/jira/browse/SPARK-28854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Yang Ang updated SPARK-28854:
-
Description:
scala> sc.parallelize(Seq(1, 2, 3)).mapPartitions(xs =>
[
https://issues.apache.org/jira/browse/SPARK-28854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Yang Ang updated SPARK-28854:
-
Description:
scala> sc.parallelize(Seq(1, 2, 3)).mapPartitions(xs =>
Hao Yang Ang created SPARK-28854:
Summary: Zipping iterators in mapPartitions will fail
Key: SPARK-28854
URL: https://issues.apache.org/jira/browse/SPARK-28854
Project: Spark
Issue Type: Bug
