[jira] [Closed] (FLINK-18984) Add tutorial documentation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18984. --- Resolution: Resolved > Add tutorial documentation for Python DataStream API > > > Key: FLINK-18984 > URL: https://issues.apache.org/jira/browse/FLINK-18984 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18984) Add tutorial documentation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190683#comment-17190683 ] Hequn Cheng commented on FLINK-18984: - Resolved in 1.12.0 via 5b18a7496d210eb2174bd0c7e02c67c4acf67ca9 > Add tutorial documentation for Python DataStream API > > > Key: FLINK-18984 > URL: https://issues.apache.org/jira/browse/FLINK-18984 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-19041. --- Resolution: Resolved > Add dependency management for ConnectedStream in Python DataStream API. > --- > > Key: FLINK-19041 > URL: https://issues.apache.org/jira/browse/FLINK-19041 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.0 >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > We failed to set merged configurations into > DataStreamTwoInputPythonStatelessFunctionOperator when finally generating the > StreamGraph. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184825#comment-17184825 ] Hequn Cheng commented on FLINK-19041: - Resolved in 1.12.0 via 66797ac6352c38c98e310fd2b34aa39088a6eacb > Add dependency management for ConnectedStream in Python DataStream API. > --- > > Key: FLINK-19041 > URL: https://issues.apache.org/jira/browse/FLINK-19041 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.0 >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > We failed to set merged configurations into > DataStreamTwoInputPythonStatelessFunctionOperator when finally generating the > StreamGraph. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-19041: Affects Version/s: 1.12.0 > Add dependency management for ConnectedStream in Python DataStream API. > --- > > Key: FLINK-19041 > URL: https://issues.apache.org/jira/browse/FLINK-19041 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.0 >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > We failed to set merged configurations into > DataStreamTwoInputPythonStatelessFunctionOperator when finally generating the > StreamGraph. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-19041: --- Assignee: Shuiqiang Chen > Add dependency management for ConnectedStream in Python DataStream API. > --- > > Key: FLINK-19041 > URL: https://issues.apache.org/jira/browse/FLINK-19041 > Project: Flink > Issue Type: Bug > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > We failed to set merged configurations into > DataStreamTwoInputPythonStatelessFunctionOperator when finally generating the > StreamGraph. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section
[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180918#comment-17180918 ] Hequn Cheng commented on FLINK-18912: - Resolved in 1.12.0 via 6ddc9b8d2718d3c005aa76365b82cf8b3e9b798e > Add a Table API tutorial link(linked to try-flink/python_table_api.md) under > the "Python API" -> "GettingStart" -> "Tutorial" section > -- > > Key: FLINK-18912 > URL: https://issues.apache.org/jira/browse/FLINK-18912 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Wei Zhong >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18953) Add documentation for DataTypes in Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180917#comment-17180917 ] Hequn Cheng commented on FLINK-18953: - Resolved in 1.12.0 via 8f7e40c9f77f822ff23265d15dc90f126c8bccd6 > Add documentation for DataTypes in Python DataStream API > > > Key: FLINK-18953 > URL: https://issues.apache.org/jira/browse/FLINK-18953 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18953) Add documentation for DataTypes in Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18953. --- Resolution: Resolved > Add documentation for DataTypes in Python DataStream API > > > Key: FLINK-18953 > URL: https://issues.apache.org/jira/browse/FLINK-18953 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18997) Rename type_info to result_type to make it more clear
[
https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180427#comment-17180427
]
Hequn Cheng commented on FLINK-18997:
-
Resolved in 1.12.0 via 0522827b27eb6a1351f9a2ebafc38eb58dbf1e57 and
183f4c1ccf0074aa8138f1f1c88bdeb68cc9d4f4
> Rename type_info to result_type to make it more clear
> -
>
> Key: FLINK-18997
> URL: https://issues.apache.org/jira/browse/FLINK-18997
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
>Reporter: Hequn Cheng
>Assignee: Hequn Cheng
>Priority: Major
> Labels: pull-request-available
> Fix For: 1.12.0
>
>
> Currently, the name of result type parameter for Python DataStream.map() and
> flat_map() is type_info.
> {code}
> def map(self, func: Union[Callable, MapFunction], type_info:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
> I think rename it to result_type would be more clear for users.
> {code}
> def map(self, func: Union[Callable, MapFunction], result_type:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Closed] (FLINK-18997) Rename type_info to result_type to make it more clear
[
https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-18997.
---
Resolution: Resolved
> Rename type_info to result_type to make it more clear
> -
>
> Key: FLINK-18997
> URL: https://issues.apache.org/jira/browse/FLINK-18997
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
>Reporter: Hequn Cheng
>Assignee: Hequn Cheng
>Priority: Major
> Labels: pull-request-available
> Fix For: 1.12.0
>
>
> Currently, the name of result type parameter for Python DataStream.map() and
> flat_map() is type_info.
> {code}
> def map(self, func: Union[Callable, MapFunction], type_info:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
> I think rename it to result_type would be more clear for users.
> {code}
> def map(self, func: Union[Callable, MapFunction], result_type:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-18997) Rename type_info to result_type to make it more clear
[
https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-18997:
Description:
Currently, the name of result type parameter for Python DataStream.map() and
flat_map() is type_info.
{code}
def map(self, func: Union[Callable, MapFunction], type_info:
TypeInformation = None) \
-> 'DataStream':
{code}
I think rename it to result_type would be more clear for users.
{code}
def map(self, func: Union[Callable, MapFunction], result_type:
TypeInformation = None) \
-> 'DataStream':
{code}
> Rename type_info to result_type to make it more clear
> -
>
> Key: FLINK-18997
> URL: https://issues.apache.org/jira/browse/FLINK-18997
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
>Reporter: Hequn Cheng
>Assignee: Hequn Cheng
>Priority: Major
> Fix For: 1.12.0
>
>
> Currently, the name of result type parameter for Python DataStream.map() and
> flat_map() is type_info.
> {code}
> def map(self, func: Union[Callable, MapFunction], type_info:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
> I think rename it to result_type would be more clear for users.
> {code}
> def map(self, func: Union[Callable, MapFunction], result_type:
> TypeInformation = None) \
> -> 'DataStream':
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-18997) Rename type_info to result_type to make it more clear
Hequn Cheng created FLINK-18997: --- Summary: Rename type_info to result_type to make it more clear Key: FLINK-18997 URL: https://issues.apache.org/jira/browse/FLINK-18997 Project: Flink Issue Type: Improvement Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18985) Update the Sphinx doc for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18985. --- Resolution: Resolved > Update the Sphinx doc for Python DataStream API. > - > > Key: FLINK-18985 > URL: https://issues.apache.org/jira/browse/FLINK-18985 > Project: Flink > Issue Type: Sub-task > Components: API / Python, Documentation >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18985) Update the Sphinx doc for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180199#comment-17180199 ] Hequn Cheng commented on FLINK-18985: - Resolved in 1.12.0 via ebab7f1d9e4ff686dd27adda45466530f20a55eb > Update the Sphinx doc for Python DataStream API. > - > > Key: FLINK-18985 > URL: https://issues.apache.org/jira/browse/FLINK-18985 > Project: Flink > Issue Type: Sub-task > Components: API / Python, Documentation >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18985) Update the Sphinx doc for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18985: Component/s: Documentation > Update the Sphinx doc for Python DataStream API. > - > > Key: FLINK-18985 > URL: https://issues.apache.org/jira/browse/FLINK-18985 > Project: Flink > Issue Type: Sub-task > Components: API / Python, Documentation >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18985) Update the Sphinx doc for Python DataStream API.
Hequn Cheng created FLINK-18985: --- Summary: Update the Sphinx doc for Python DataStream API. Key: FLINK-18985 URL: https://issues.apache.org/jira/browse/FLINK-18985 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18984) Add tutorial documentation for Python DataStream API
Hequn Cheng created FLINK-18984: --- Summary: Add tutorial documentation for Python DataStream API Key: FLINK-18984 URL: https://issues.apache.org/jira/browse/FLINK-18984 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18949) Support Streaming File Sink for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179439#comment-17179439 ] Hequn Cheng commented on FLINK-18949: - Resolved in 1.12.0 via 46e04daa565854e78c3bbc9b2da23c7cddaf3d5e > Support Streaming File Sink for Python DataStream API > - > > Key: FLINK-18949 > URL: https://issues.apache.org/jira/browse/FLINK-18949 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18949) Support Streaming File Sink for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18949. --- Resolution: Resolved > Support Streaming File Sink for Python DataStream API > - > > Key: FLINK-18949 > URL: https://issues.apache.org/jira/browse/FLINK-18949 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-18954) Add documentation for connectors in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179380#comment-17179380 ] Hequn Cheng edited comment on FLINK-18954 at 8/18/20, 6:11 AM: --- Rename this Jira to support documentation for connectors was (Author: hequn8128): Close this Jira for now since currently MapFunction/FlatMapFunction does not contain the open method in which metrics need to be initialized. > Add documentation for connectors in Python DataStream API. > -- > > Key: FLINK-18954 > URL: https://issues.apache.org/jira/browse/FLINK-18954 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Reopened] (FLINK-18954) Add documentation for connectors in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-18954: - > Add documentation for connectors in Python DataStream API. > -- > > Key: FLINK-18954 > URL: https://issues.apache.org/jira/browse/FLINK-18954 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18954: Summary: Add documentation for connectors in Python DataStream API. (was: Add documentation for Metrics in Python DataStream API.) > Add documentation for connectors in Python DataStream API. > -- > > Key: FLINK-18954 > URL: https://issues.apache.org/jira/browse/FLINK-18954 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18954) Add documentation for Metrics in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18954. --- Resolution: Later > Add documentation for Metrics in Python DataStream API. > --- > > Key: FLINK-18954 > URL: https://issues.apache.org/jira/browse/FLINK-18954 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18954) Add documentation for Metrics in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179380#comment-17179380 ] Hequn Cheng commented on FLINK-18954: - Close this Jira for now since currently MapFunction/FlatMapFunction does not contain the open method in which metrics need to be initialized. > Add documentation for Metrics in Python DataStream API. > --- > > Key: FLINK-18954 > URL: https://issues.apache.org/jira/browse/FLINK-18954 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18944) Support JDBC connector for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18944. --- Resolution: Resolved > Support JDBC connector for Python DataStream API > > > Key: FLINK-18944 > URL: https://issues.apache.org/jira/browse/FLINK-18944 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18944) Support JDBC connector for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179360#comment-17179360 ] Hequn Cheng commented on FLINK-18944: - Resolved in 1.12.0 via f674c7c9c5bf733b77e661e9ecc74c60d7fc906e > Support JDBC connector for Python DataStream API > > > Key: FLINK-18944 > URL: https://issues.apache.org/jira/browse/FLINK-18944 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18886) Support Kafka connectors for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179295#comment-17179295 ] Hequn Cheng commented on FLINK-18886: - Resolved in 1.12.0 via 3c61dac47c015a2d3fc5f70149d812e73ec8220e > Support Kafka connectors for Python DataStream API > -- > > Key: FLINK-18886 > URL: https://issues.apache.org/jira/browse/FLINK-18886 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18886) Support Kafka connectors for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18886. --- Resolution: Resolved > Support Kafka connectors for Python DataStream API > -- > > Key: FLINK-18886 > URL: https://issues.apache.org/jira/browse/FLINK-18886 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18947) Support partitionCustom() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179294#comment-17179294 ] Hequn Cheng commented on FLINK-18947: - Resolved in 1.12.0 via 917c3d2f294f17ea8031dce2220f142c67520463 > Support partitionCustom() operation for Python DataStream API > - > > Key: FLINK-18947 > URL: https://issues.apache.org/jira/browse/FLINK-18947 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: shuiqiangchen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18947) Support partitionCustom() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18947. --- Resolution: Resolved > Support partitionCustom() operation for Python DataStream API > - > > Key: FLINK-18947 > URL: https://issues.apache.org/jira/browse/FLINK-18947 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: shuiqiangchen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18966. --- Resolution: Resolved > Support key_by() on ConnectedStreams for Python DataStream API > -- > > Key: FLINK-18966 > URL: https://issues.apache.org/jira/browse/FLINK-18966 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178851#comment-17178851 ] Hequn Cheng commented on FLINK-18966: - Resolved in 1.12.0 via 445398cd6f636320092832393ca6ac48b27f98c8 > Support key_by() on ConnectedStreams for Python DataStream API > -- > > Key: FLINK-18966 > URL: https://issues.apache.org/jira/browse/FLINK-18966 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18948) Add end to end test for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18948: --- Assignee: Shuiqiang Chen (was: shuiqiangchen ) > Add end to end test for Python DataStream API > - > > Key: FLINK-18948 > URL: https://issues.apache.org/jira/browse/FLINK-18948 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section
[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18912: --- Assignee: Hequn Cheng > Add a Table API tutorial link(linked to try-flink/python_table_api.md) under > the "Python API" -> "GettingStart" -> "Tutorial" section > -- > > Key: FLINK-18912 > URL: https://issues.apache.org/jira/browse/FLINK-18912 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Wei Zhong >Assignee: Hequn Cheng >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section
[ https://issues.apache.org/jira/browse/FLINK-18918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18918: --- Assignee: Hequn Cheng > Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table > API" section > -- > > Key: FLINK-18918 > URL: https://issues.apache.org/jira/browse/FLINK-18918 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Wei Zhong >Assignee: Hequn Cheng >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18945) Support CoFlatMap for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18945. --- Resolution: Resolved > Support CoFlatMap for Python DataStream API > --- > > Key: FLINK-18945 > URL: https://issues.apache.org/jira/browse/FLINK-18945 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18945) Support CoFlatMap for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178474#comment-17178474 ] Hequn Cheng commented on FLINK-18945: - Resolved in 1.12.0 via ecc342904404c272939196cb9b30803cc518faa6 > Support CoFlatMap for Python DataStream API > --- > > Key: FLINK-18945 > URL: https://issues.apache.org/jira/browse/FLINK-18945 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18943) Support CoMapFunction for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178449#comment-17178449 ] Hequn Cheng commented on FLINK-18943: - Resolved in 1.12.0 via 175038b705f82655a4a082de64a73f989f6abea4 and a86387bfa9ac525223b8e16b0a747d35893c9302 > Support CoMapFunction for Python DataStream API > --- > > Key: FLINK-18943 > URL: https://issues.apache.org/jira/browse/FLINK-18943 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18943) Support CoMapFunction for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18943. --- Resolution: Resolved > Support CoMapFunction for Python DataStream API > --- > > Key: FLINK-18943 > URL: https://issues.apache.org/jira/browse/FLINK-18943 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink
[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18879. --- Resolution: Resolved > Support Row Serialization and Deserialization schemas for DataStream > source/sink > > > Key: FLINK-18879 > URL: https://issues.apache.org/jira/browse/FLINK-18879 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > There are many built-in RowSerializationSchemas and RowDeserializationSchemas > for DataStream Source and Sink, like JsonRow(De)SerializationSchema, > AvroRow(De)SerializationSchema. In Python DataStream API, we will also > support these schemas. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink
[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178190#comment-17178190 ] Hequn Cheng commented on FLINK-18879: - Resolve in 1.12.0 via 1fc400d1f94a10d2f5b227cc8eaa1ac9754ec237 > Support Row Serialization and Deserialization schemas for DataStream > source/sink > > > Key: FLINK-18879 > URL: https://issues.apache.org/jira/browse/FLINK-18879 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > There are many built-in RowSerializationSchemas and RowDeserializationSchemas > for DataStream Source and Sink, like JsonRow(De)SerializationSchema, > AvroRow(De)SerializationSchema. In Python DataStream API, we will also > support these schemas. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18945) Support CoFlatMap for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18945: Summary: Support CoFlatMap for Python DataStream API (was: Support key_by() on ConnectedStreams for Python DataStream API) > Support CoFlatMap for Python DataStream API > --- > > Key: FLINK-18945 > URL: https://issues.apache.org/jira/browse/FLINK-18945 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API
Hequn Cheng created FLINK-18966: --- Summary: Support key_by() on ConnectedStreams for Python DataStream API Key: FLINK-18966 URL: https://issues.apache.org/jira/browse/FLINK-18966 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18943) Support CoMapFunction for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18943: Summary: Support CoMapFunction for Python DataStream API (was: Support connect() operation for Python DataStream API) > Support CoMapFunction for Python DataStream API > --- > > Key: FLINK-18943 > URL: https://issues.apache.org/jira/browse/FLINK-18943 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18884. --- Resolution: Resolved > Add chaining strategy and slot sharing group interfaces for Python DataStream > API > - > > Key: FLINK-18884 > URL: https://issues.apache.org/jira/browse/FLINK-18884 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177673#comment-17177673 ] Hequn Cheng commented on FLINK-18884: - Resolved in 1.12.0 via d3aa4f326d76dd214ca73252b8bdf3e63a497a3e > Add chaining strategy and slot sharing group interfaces for Python DataStream > API > - > > Key: FLINK-18884 > URL: https://issues.apache.org/jira/browse/FLINK-18884 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18765) Support map() and flat_map() for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18765: --- Assignee: Shuiqiang Chen > Support map() and flat_map() for Python DataStream API > -- > > Key: FLINK-18765 > URL: https://issues.apache.org/jira/browse/FLINK-18765 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18764) Support from_collection for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18764: --- Assignee: Shuiqiang Chen > Support from_collection for Python DataStream API > - > > Key: FLINK-18764 > URL: https://issues.apache.org/jira/browse/FLINK-18764 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18886) Support Kafka connectors for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18886: --- Assignee: Shuiqiang Chen > Support Kafka connectors for Python DataStream API > -- > > Key: FLINK-18886 > URL: https://issues.apache.org/jira/browse/FLINK-18886 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18884: --- Assignee: Shuiqiang Chen > Add chaining strategy and slot sharing group interfaces for Python DataStream > API > - > > Key: FLINK-18884 > URL: https://issues.apache.org/jira/browse/FLINK-18884 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18944) Support JDBC connector for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18944: --- Assignee: Shuiqiang Chen > Support JDBC connector for Python DataStream API > > > Key: FLINK-18944 > URL: https://issues.apache.org/jira/browse/FLINK-18944 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink
[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18879: --- Assignee: Shuiqiang Chen > Support Row Serialization and Deserialization schemas for DataStream > source/sink > > > Key: FLINK-18879 > URL: https://issues.apache.org/jira/browse/FLINK-18879 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > > There are many built-in RowSerializationSchemas and RowDeserializationSchemas > for DataStream Source and Sink, like JsonRow(De)SerializationSchema, > AvroRow(De)SerializationSchema. In Python DataStream API, we will also > support these schemas. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18887) Add ElasticSearch connector for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18887: --- Assignee: Shuiqiang Chen > Add ElasticSearch connector for Python DataStream API > - > > Key: FLINK-18887 > URL: https://issues.apache.org/jira/browse/FLINK-18887 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18945) Support key_by() on ConnectedStreams for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18945: --- Assignee: Hequn Cheng > Support key_by() on ConnectedStreams for Python DataStream API > -- > > Key: FLINK-18945 > URL: https://issues.apache.org/jira/browse/FLINK-18945 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18946) Support Cassandra connector for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18946: --- Assignee: Shuiqiang Chen > Support Cassandra connector for Python DataStream API > - > > Key: FLINK-18946 > URL: https://issues.apache.org/jira/browse/FLINK-18946 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18947) Support partitionCustom() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18947: --- Assignee: shuiqiangchen > Support partitionCustom() operation for Python DataStream API > - > > Key: FLINK-18947 > URL: https://issues.apache.org/jira/browse/FLINK-18947 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: shuiqiangchen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18943) Support connect() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18943: --- Assignee: Hequn Cheng > Support connect() operation for Python DataStream API > - > > Key: FLINK-18943 > URL: https://issues.apache.org/jira/browse/FLINK-18943 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18949) Support Streaming File Sink for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18949: --- Assignee: Hequn Cheng > Support Streaming File Sink for Python DataStream API > - > > Key: FLINK-18949 > URL: https://issues.apache.org/jira/browse/FLINK-18949 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18951) Add documentation for Configurations in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18951: --- Assignee: Shuiqiang Chen > Add documentation for Configurations in Python DataStream API. > --- > > Key: FLINK-18951 > URL: https://issues.apache.org/jira/browse/FLINK-18951 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18950) Add documentation for Operations in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18950: --- Assignee: Shuiqiang Chen > Add documentation for Operations in Python DataStream API. > --- > > Key: FLINK-18950 > URL: https://issues.apache.org/jira/browse/FLINK-18950 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18948) Add end to end test for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18948: --- Assignee: shuiqiangchen > Add end to end test for Python DataStream API > - > > Key: FLINK-18948 > URL: https://issues.apache.org/jira/browse/FLINK-18948 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: shuiqiangchen >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18952) Add 10 minutes to DataStream API documentation
[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18952: --- Assignee: Hequn Cheng > Add 10 minutes to DataStream API documentation > -- > > Key: FLINK-18952 > URL: https://issues.apache.org/jira/browse/FLINK-18952 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18953) Add documentation for DataTypes in Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18953: --- Assignee: Hequn Cheng > Add documentation for DataTypes in Python DataStream API > > > Key: FLINK-18953 > URL: https://issues.apache.org/jira/browse/FLINK-18953 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18952) Add 10 minutes to DataStream API documentation
Hequn Cheng created FLINK-18952: --- Summary: Add 10 minutes to DataStream API documentation Key: FLINK-18952 URL: https://issues.apache.org/jira/browse/FLINK-18952 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18954) Add documentation for Metrics in Python DataStream API.
Hequn Cheng created FLINK-18954: --- Summary: Add documentation for Metrics in Python DataStream API. Key: FLINK-18954 URL: https://issues.apache.org/jira/browse/FLINK-18954 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18953) Add documentation for DataTypes in Python DataStream API
Hequn Cheng created FLINK-18953: --- Summary: Add documentation for DataTypes in Python DataStream API Key: FLINK-18953 URL: https://issues.apache.org/jira/browse/FLINK-18953 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18949) Support Streaming File Sink for Python DataStream API
Hequn Cheng created FLINK-18949: --- Summary: Support Streaming File Sink for Python DataStream API Key: FLINK-18949 URL: https://issues.apache.org/jira/browse/FLINK-18949 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18948) Add end to end test for Python DataStream API
Hequn Cheng created FLINK-18948: --- Summary: Add end to end test for Python DataStream API Key: FLINK-18948 URL: https://issues.apache.org/jira/browse/FLINK-18948 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18947) Support partitionCustom() operation for Python DataStream API
Hequn Cheng created FLINK-18947: --- Summary: Support partitionCustom() operation for Python DataStream API Key: FLINK-18947 URL: https://issues.apache.org/jira/browse/FLINK-18947 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18945) Support key_by() on ConnectedStreams for Python DataStream API
Hequn Cheng created FLINK-18945: --- Summary: Support key_by() on ConnectedStreams for Python DataStream API Key: FLINK-18945 URL: https://issues.apache.org/jira/browse/FLINK-18945 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18943) Support connect() operation for Python DataStream API
Hequn Cheng created FLINK-18943: --- Summary: Support connect() operation for Python DataStream API Key: FLINK-18943 URL: https://issues.apache.org/jira/browse/FLINK-18943 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18878. --- Resolution: Resolved > Support dependency management for Python StreamExecutionEnvironment. > > > Key: FLINK-18878 > URL: https://issues.apache.org/jira/browse/FLINK-18878 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Add dependency management for StreamExecutionEnvironment when Users need to > specified third party dependencies in their DataStream Job. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18878: --- Assignee: Shuiqiang Chen > Support dependency management for Python StreamExecutionEnvironment. > > > Key: FLINK-18878 > URL: https://issues.apache.org/jira/browse/FLINK-18878 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Add dependency management for StreamExecutionEnvironment when Users need to > specified third party dependencies in their DataStream Job. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177431#comment-17177431 ] Hequn Cheng commented on FLINK-18878: - Resolved in 1.12.0 via 62b20b0c596c77ebf089394d37959c1bec53aee1 > Support dependency management for Python StreamExecutionEnvironment. > > > Key: FLINK-18878 > URL: https://issues.apache.org/jira/browse/FLINK-18878 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Add dependency management for StreamExecutionEnvironment when Users need to > specified third party dependencies in their DataStream Job. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176260#comment-17176260 ] Hequn Cheng commented on FLINK-1: - Resolved in 1.12.0 via 5dadbf312bb103dd3e8e812ac42a909479e2ca8a > Support execute_async for StreamExecutionEnvironment. > - > > Key: FLINK-1 > URL: https://issues.apache.org/jira/browse/FLINK-1 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-1. --- Resolution: Resolved > Support execute_async for StreamExecutionEnvironment. > - > > Key: FLINK-1 > URL: https://issues.apache.org/jira/browse/FLINK-1 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-1: --- Assignee: Shuiqiang Chen > Support execute_async for StreamExecutionEnvironment. > - > > Key: FLINK-1 > URL: https://issues.apache.org/jira/browse/FLINK-1 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18885) Add partitioning interfaces for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18885. --- Resolution: Resolved > Add partitioning interfaces for Python DataStream API. > -- > > Key: FLINK-18885 > URL: https://issues.apache.org/jira/browse/FLINK-18885 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18885) Add partitioning interfaces for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18885: --- Assignee: Shuiqiang Chen > Add partitioning interfaces for Python DataStream API. > -- > > Key: FLINK-18885 > URL: https://issues.apache.org/jira/browse/FLINK-18885 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18885) Add partitioning interfaces for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176106#comment-17176106 ] Hequn Cheng commented on FLINK-18885: - Resolved in 1.12.0 via 82b3669d277b145a06bf818432efbd73e5423246 > Add partitioning interfaces for Python DataStream API. > -- > > Key: FLINK-18885 > URL: https://issues.apache.org/jira/browse/FLINK-18885 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18863. --- Resolution: Resolved > Support read_text_file() and print() interface for Python DataStream API. > -- > > Key: FLINK-18863 > URL: https://issues.apache.org/jira/browse/FLINK-18863 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support print() and read_text_file() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175931#comment-17175931 ] Hequn Cheng commented on FLINK-18863: - Resolved in 1.12.0 via 37d7917bc175026cc09f4842f38fea6b0cc818cd > Support read_text_file() and print() interface for Python DataStream API. > -- > > Key: FLINK-18863 > URL: https://issues.apache.org/jira/browse/FLINK-18863 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support print() and read_text_file() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18866) Support filter() operation for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175490#comment-17175490 ] Hequn Cheng commented on FLINK-18866: - Resolved in 1.12.0 via f1e34e659aed9f7bbf7cd7c38e10e97ca88e4b73 > Support filter() operation for Python DataStream API. > - > > Key: FLINK-18866 > URL: https://issues.apache.org/jira/browse/FLINK-18866 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support filter() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18866) Support filter() operation for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18866. --- Resolution: Resolved > Support filter() operation for Python DataStream API. > - > > Key: FLINK-18866 > URL: https://issues.apache.org/jira/browse/FLINK-18866 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support filter() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18883) Support reduce() operation for Python KeyedStream.
[ https://issues.apache.org/jira/browse/FLINK-18883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18883. --- Resolution: Resolved > Support reduce() operation for Python KeyedStream. > -- > > Key: FLINK-18883 > URL: https://issues.apache.org/jira/browse/FLINK-18883 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18883) Support reduce() operation for Python KeyedStream.
[ https://issues.apache.org/jira/browse/FLINK-18883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175392#comment-17175392 ] Hequn Cheng commented on FLINK-18883: - Resolved in 1.12.0 via 240a1e83406d361a40f4117e249154b03fd80325 > Support reduce() operation for Python KeyedStream. > -- > > Key: FLINK-18883 > URL: https://issues.apache.org/jira/browse/FLINK-18883 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18874) Support conversion between Table and DataStream
[ https://issues.apache.org/jira/browse/FLINK-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18874: --- Assignee: Shuiqiang Chen > Support conversion between Table and DataStream > --- > > Key: FLINK-18874 > URL: https://issues.apache.org/jira/browse/FLINK-18874 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support Converting a DataStream into a Table, and a Table to append/retract > Stream. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18874) Support conversion between Table and DataStream
[ https://issues.apache.org/jira/browse/FLINK-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175261#comment-17175261 ] Hequn Cheng commented on FLINK-18874: - Resolved in 1.12.0 via 8b9193a737e9f32ecad1f0da7c30b734d8990b5f > Support conversion between Table and DataStream > --- > > Key: FLINK-18874 > URL: https://issues.apache.org/jira/browse/FLINK-18874 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support Converting a DataStream into a Table, and a Table to append/retract > Stream. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18874) Support conversion between Table and DataStream
[ https://issues.apache.org/jira/browse/FLINK-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18874. --- Resolution: Resolved > Support conversion between Table and DataStream > --- > > Key: FLINK-18874 > URL: https://issues.apache.org/jira/browse/FLINK-18874 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support Converting a DataStream into a Table, and a Table to append/retract > Stream. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18883) Support reduce() operation for Python KeyedStream.
Hequn Cheng created FLINK-18883: --- Summary: Support reduce() operation for Python KeyedStream. Key: FLINK-18883 URL: https://issues.apache.org/jira/browse/FLINK-18883 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Hequn Cheng Assignee: Hequn Cheng Fix For: 1.12.0 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18863: --- Assignee: Shuiqiang Chen > Support read_text_file() and print() interface for Python DataStream API. > -- > > Key: FLINK-18863 > URL: https://issues.apache.org/jira/browse/FLINK-18863 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > > Support print() and read_text_file() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18863: Description: Support print() and read_text_file() interface for Python DataStream API. (was: Support print() and write_as_text() interface for Python DataStream API.) > Support read_text_file() and print() interface for Python DataStream API. > -- > > Key: FLINK-18863 > URL: https://issues.apache.org/jira/browse/FLINK-18863 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Priority: Major > Fix For: 1.12.0 > > > Support print() and read_text_file() interface for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment
[ https://issues.apache.org/jira/browse/FLINK-18861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18861. --- Resolution: Resolved > Support add_source() to get a DataStream for Python StreamExecutionEnvironment > -- > > Key: FLINK-18861 > URL: https://issues.apache.org/jira/browse/FLINK-18861 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support add_source() to get a DataStream for Python > StreamExecutionEnvironment. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment
[ https://issues.apache.org/jira/browse/FLINK-18861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175142#comment-17175142 ] Hequn Cheng commented on FLINK-18861: - Resolved in 1.12.0 via 0dad895b03ece20008b1a3194bc960c4709df878 > Support add_source() to get a DataStream for Python StreamExecutionEnvironment > -- > > Key: FLINK-18861 > URL: https://issues.apache.org/jira/browse/FLINK-18861 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support add_source() to get a DataStream for Python > StreamExecutionEnvironment. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18864) Support key_by() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175140#comment-17175140 ] Hequn Cheng commented on FLINK-18864: - Resolved in 1.12.0 via fa9e4a5ec330998239c9a8e6f974da5bb8c1599b > Support key_by() operation for Python DataStream API > > > Key: FLINK-18864 > URL: https://issues.apache.org/jira/browse/FLINK-18864 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support key_by() operation for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18864) Support key_by() operation for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18864. --- Resolution: Resolved > Support key_by() operation for Python DataStream API > > > Key: FLINK-18864 > URL: https://issues.apache.org/jira/browse/FLINK-18864 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Shuiqiang Chen >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > > Support key_by() operation for Python DataStream API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-18766) Support add_sink() for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18766. --- Resolution: Resolved > Support add_sink() for Python DataStream API > > > Key: FLINK-18766 > URL: https://issues.apache.org/jira/browse/FLINK-18766 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-18766) Support add_sink() for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18766: Fix Version/s: 1.12.0 > Support add_sink() for Python DataStream API > > > Key: FLINK-18766 > URL: https://issues.apache.org/jira/browse/FLINK-18766 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18766) Support add_sink() for Python DataStream API
[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174240#comment-17174240 ] Hequn Cheng commented on FLINK-18766: - Resolved in 1.12.0 via b8d2ed787f89c97b47ab2d212a7f3b0e4cc57d50 > Support add_sink() for Python DataStream API > > > Key: FLINK-18766 > URL: https://issues.apache.org/jira/browse/FLINK-18766 > Project: Flink > Issue Type: Sub-task > Components: API / Python >Reporter: Hequn Cheng >Assignee: Shuiqiang Chen >Priority: Major > Labels: pull-request-available > -- This message was sent by Atlassian Jira (v8.3.4#803005)
