[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931953#comment-15931953 ] Geoffrey Mon commented on FLINK-5183: - Thanks for your help! > [py] Support multiple

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15702931#comment-15702931 ] Geoffrey Mon commented on FLINK-4098: - A working implementation is available here: ht

[jira] [Created] (FLINK-5183) [py] Support multiple jobs per Python plan file

Geoffrey Mon created FLINK-5183: --- Summary: [py] Support multiple jobs per Python plan file Key: FLINK-5183 URL: https://issues.apache.org/jira/browse/FLINK-5183 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15344559#comment-15344559 ] Geoffrey Mon commented on FLINK-4098: - See https://github.com/GEOFBOT/flink/commit/2a

[jira] [Comment Edited] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15344559#comment-15344559 ] Geoffrey Mon edited comment on FLINK-4098 at 6/22/16 3:49 PM: --

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346600#comment-15346600 ] Geoffrey Mon commented on FLINK-4098: - Here's a jobmanager log for a simple Python ite

[jira] [Comment Edited] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346600#comment-15346600 ] Geoffrey Mon edited comment on FLINK-4098 at 6/23/16 3:26 PM: --

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346664#comment-15346664 ] Geoffrey Mon commented on FLINK-4098: - Maybe it would be simpler to implement iteratio

[jira] [Issue Comment Deleted] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoffrey Mon updated FLINK-4098: Comment: was deleted (was: Maybe it would be simpler to implement iterations in Python similar to a

[jira] [Commented] (FLINK-4098) Iteration support in Python API

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

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ 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. Afte

[jira] [Comment Edited] (FLINK-4098) Iteration support in Python API

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

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350387#comment-15350387 ] Geoffrey Mon commented on FLINK-4098: - Sorry, I must have made a typo in the previous

[jira] [Comment Edited] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350387#comment-15350387 ] Geoffrey Mon edited comment on FLINK-4098 at 6/27/16 3:28 AM: --

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355350#comment-15355350 ] Geoffrey Mon commented on FLINK-4098: - I've further confirmed that the issue is that d

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15360261#comment-15360261 ] Geoffrey Mon commented on FLINK-4098: - I got bulk iterations to work by removing a che

[jira] [Commented] (FLINK-4098) Iteration support in Python API

[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362646#comment-15362646 ] Geoffrey Mon commented on FLINK-4098: - That would explain the issue I had earlier. I'v

[jira] [Created] (FLINK-5948) Error in Python zip_with_index documentation

Geoffrey Mon created FLINK-5948: --- Summary: Error in Python zip_with_index documentation Key: FLINK-5948 URL: https://issues.apache.org/jira/browse/FLINK-5948 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839961#comment-15839961 ] Geoffrey Mon commented on FLINK-5183: - I'm currently working on this at https://githu

[jira] [Comment Edited] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839961#comment-15839961 ] Geoffrey Mon edited comment on FLINK-5183 at 1/26/17 4:48 PM: --

[jira] [Comment Edited] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839961#comment-15839961 ] Geoffrey Mon edited comment on FLINK-5183 at 1/26/17 5:21 PM: --

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15840525#comment-15840525 ] Geoffrey Mon commented on FLINK-5183: - That solved the problem. I was really overthink

[jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API

Geoffrey Mon created FLINK-4017: --- Summary: [py] Add Aggregation support to Python API Key: FLINK-4017 URL: https://issues.apache.org/jira/browse/FLINK-4017 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318676#comment-15318676 ] Geoffrey Mon commented on FLINK-4017: - At least one of the issues I have come across i

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318713#comment-15318713 ] Geoffrey Mon commented on FLINK-4017: - Thanks for the advice. The issue that was hinde

[jira] [Created] (FLINK-4098) Iteration support in Python API

Geoffrey Mon created FLINK-4098: --- Summary: Iteration support in Python API Key: FLINK-4098 URL: https://issues.apache.org/jira/browse/FLINK-4098 Project: Flink Issue Type: New Feature