flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4098) Iteration support in Python API
Date Wed, 22 Jun 2016 15:57:57 GMT

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

Mime
View raw message