flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Geoffrey Mon (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (FLINK-4098) Iteration support in Python API
Date Fri, 24 Jun 2016 15:35:16 GMT

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

Geoffrey Mon edited comment on FLINK-4098 at 6/24/16 3:34 PM:
--------------------------------------------------------------

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.

EDIT: More specifically, {{Iterator.getNext()}} of the iterator in {{PythonStreamer.streamBufferWithoutGroups}}
hangs.


was (Author: hydronium):
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)

Mime
View raw message