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

[ASF GitHub Bot (JIRA)]

Title: Message Title

ASF GitHub Bot commented on FLINK-5183   Re: [py] Support multiple jobs per Python plan file Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3232#discussion_r98443208 — Diff: flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/PythonMapPartition.java — @@ -32,7 +32,7 @@ private final PythonStreamer streamer; private transient final TypeInformation<OUT> typeInformation; public PythonMapPartition(int id, TypeInformation<OUT> typeInformation) { + public PythonMapPartition(String id, TypeInformation<OUT> typeInformation) { End diff – i would propose explicitly passing the envID and setID. Makes it a lot clearer, and we don't have to split a string that we created a second ago. Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)