[ 
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15344590#comment-15344590
 ] 

Chesnay Schepler commented on FLINK-4098:
-----------------------------------------

could you add some simple print statements in the MapFunction class to see 
whether the first iteration works correctly?

I'll have to look into the java lifecycle of iterations to provide a better 
assessment, but i have a hunch it's related to the assumption that an operator 
is only used once, and not multiple times as is the case for iterations.

> 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)

Reply via email to