[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346713#comment-15346713
]
Geoffrey Mon commented on FLINK-4098:
-------------------------------------
After adding some more print statements in different places, I found that while
running a normal {{.map()}} on a DataSet caused {{MapFunction._run()}},
{{MapFunction._configure()}}, and {{MapFunction.collect()}} to run, running
{{.map()}} as an iteration caused none of these functions to run. The
MapFunction instance was initialized but never used. Does this mean the Java
side of Flink was waiting for the Python side to return its results, causing
the hang?
> 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)
