[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347577#comment-15347577
]
Geoffrey Mon commented on FLINK-4098:
-------------------------------------
Thanks for the {{sys.stdout.flush()}} tip. After adding more debug statements,
I found out that the real issue is in the Iterator, when next() is called, the
function starts but hangs waiting for data to be sent so that it can be read.
> 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)
