[jira] [Closed] (FLINK-18984) Add tutorial documentation for Python DataStream API

2020-09-04 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18984) Add tutorial documentation for Python DataStream API

2020-09-04 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.

2020-08-25 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.

2020-08-25 Thread Hequn Cheng (Jira)
[ 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

[jira] [Updated] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.

2020-08-25 Thread Hequn Cheng (Jira)
[ 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

[jira] [Assigned] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.

2020-08-25 Thread Hequn Cheng (Jira)
[ 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

[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

2020-08-19 Thread Hequn Cheng (Jira)
[ 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

[jira] [Commented] (FLINK-18953) Add documentation for DataTypes in Python DataStream API

2020-08-19 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18953) Add documentation for DataTypes in Python DataStream API

2020-08-19 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18997) Rename type_info to result_type to make it more clear

2020-08-19 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18997) Rename type_info to result_type to make it more clear

2020-08-19 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Updated] (FLINK-18997) Rename type_info to result_type to make it more clear

2020-08-19 Thread Hequn Cheng (Jira)
[ 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

[jira] [Created] (FLINK-18997) Rename type_info to result_type to make it more clear

2020-08-19 Thread Hequn Cheng (Jira)
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

[jira] [Closed] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Updated] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Created] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
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:

[jira] [Created] (FLINK-18984) Add tutorial documentation for Python DataStream API

2020-08-18 Thread Hequn Cheng (Jira)
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

[jira] [Commented] (FLINK-18949) Support Streaming File Sink for Python DataStream API

2020-08-18 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18949) Support Streaming File Sink for Python DataStream API

2020-08-18 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Comment Edited] (FLINK-18954) Add documentation for connectors in Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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

[jira] [Reopened] (FLINK-18954) Add documentation for connectors in Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18954) Add documentation for Metrics in Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-18954) Add documentation for Metrics in Python DataStream API.

2020-08-18 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18944) Support JDBC connector for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18944) Support JDBC connector for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Commented] (FLINK-18886) Support Kafka connectors for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18886) Support Kafka connectors for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18947) Support partitionCustom() operation for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18947) Support partitionCustom() operation for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Closed] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Assigned] (FLINK-18948) Add end to end test for Python DataStream API

2020-08-17 Thread Hequn Cheng (Jira)
[ 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

[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

2020-08-16 Thread Hequn Cheng (Jira)
[ 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

[jira] [Assigned] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section

2020-08-16 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18945) Support CoFlatMap for Python DataStream API

2020-08-16 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18945) Support CoFlatMap for Python DataStream API

2020-08-16 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Commented] (FLINK-18943) Support CoMapFunction for Python DataStream API

2020-08-16 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18943) Support CoMapFunction for Python DataStream API

2020-08-16 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Closed] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

2020-08-15 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

2020-08-15 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Updated] (FLINK-18945) Support CoFlatMap for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

[jira] [Created] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Updated] (FLINK-18943) Support CoMapFunction for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

[jira] [Commented] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Assigned] (FLINK-18765) Support map() and flat_map() for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18764) Support from_collection for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18886) Support Kafka connectors for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

[jira] [Assigned] (FLINK-18944) Support JDBC connector for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

[jira] [Assigned] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18945) Support key_by() on ConnectedStreams for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18946) Support Cassandra connector for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18947) Support partitionCustom() operation for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18943) Support connect() operation for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18949) Support Streaming File Sink for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18951) Add documentation for Configurations in Python DataStream API.

2020-08-14 Thread Hequn Cheng (Jira)
[ 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.

[jira] [Assigned] (FLINK-18950) Add documentation for Operations in Python DataStream API.

2020-08-14 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Assigned] (FLINK-18948) Add end to end test for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18952) Add 10 minutes to DataStream API documentation

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Assigned] (FLINK-18953) Add documentation for DataTypes in Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Created] (FLINK-18952) Add 10 minutes to DataStream API documentation

2020-08-14 Thread Hequn Cheng (Jira)
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:

[jira] [Created] (FLINK-18954) Add documentation for Metrics in Python DataStream API.

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Created] (FLINK-18953) Add documentation for DataTypes in Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Created] (FLINK-18949) Support Streaming File Sink for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Created] (FLINK-18948) Add end to end test for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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:

[jira] [Created] (FLINK-18947) Support partitionCustom() operation for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Created] (FLINK-18945) Support key_by() on ConnectedStreams for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Created] (FLINK-18943) Support connect() operation for Python DataStream API

2020-08-14 Thread Hequn Cheng (Jira)
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

[jira] [Closed] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.

2020-08-13 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Assigned] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.

2020-08-13 Thread Hequn Cheng (Jira)
[ 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

[jira] [Commented] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.

2020-08-13 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Commented] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Assigned] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Closed] (FLINK-18885) Add partitioning interfaces for Python DataStream API.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Assigned] (FLINK-18885) Add partitioning interfaces for Python DataStream API.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-18885) Add partitioning interfaces for Python DataStream API.

2020-08-12 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Commented] (FLINK-18866) Support filter() operation for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18866) Support filter() operation for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Closed] (FLINK-18883) Support reduce() operation for Python KeyedStream.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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. >

[jira] [Commented] (FLINK-18883) Support reduce() operation for Python KeyedStream.

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Assigned] (FLINK-18874) Support conversion between Table and DataStream

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18874) Support conversion between Table and DataStream

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18874) Support conversion between Table and DataStream

2020-08-11 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Created] (FLINK-18883) Support reduce() operation for Python KeyedStream.

2020-08-10 Thread Hequn Cheng (Jira)
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:

[jira] [Assigned] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-10 Thread Hequn Cheng (Jira)
[ 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

[jira] [Updated] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-10 Thread Hequn Cheng (Jira)
[ 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:

[jira] [Closed] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment

2020-08-10 Thread Hequn Cheng (Jira)
[ 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

[jira] [Commented] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Commented] (FLINK-18864) Support key_by() operation for Python DataStream API

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 

[jira] [Closed] (FLINK-18864) Support key_by() operation for Python DataStream API

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Closed] (FLINK-18766) Support add_sink() for Python DataStream API

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Updated] (FLINK-18766) Support add_sink() for Python DataStream API

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 >

[jira] [Commented] (FLINK-18766) Support add_sink() for Python DataStream API

2020-08-10 Thread Hequn Cheng (Jira)
[ 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 

  1   2   3   4   5   6   7   8   9   10   >