[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355350#comment-15355350
]
Geoffrey Mon commented on FLINK-4098:
-------------------------------------
I've further confirmed that the issue is that data is not being sent to Python
(and the results are not being returned). Using a map_partition function in
Python, I found that the function starts but waits indefinitely for values to
be given to its iterator. The reason the map function was not run once is
because the map function is run on each value of the iterator, so it was never
run at all.
> Iteration support in Python API
> -------------------------------
>
> Key: FLINK-4098
> URL: https://issues.apache.org/jira/browse/FLINK-4098
> Project: Flink
> Issue Type: New Feature
> Components: Python API
> Affects Versions: 1.0.2
> Reporter: Geoffrey Mon
> Priority: Minor
>
> Bulk and delta iterations are not supported in the Python API. Currently
> working on this at https://github.com/GEOFBOT/flink
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
