[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190683#comment-17190683
]
Hequn Cheng commented on FLINK-18984:
-
Resolved in 1.12.0 via 5b18a7496d210eb2174bd0
[
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.
> ---
[
https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184825#comment-17184825
]
Hequn Cheng commented on FLINK-19041:
-
Resolved in 1.12.0 via 66797ac6352c38c98e310f
[
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
[
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 DataStre
[
https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180918#comment-17180918
]
Hequn Cheng commented on FLINK-18912:
-
Resolved in 1.12.0 via 6ddc9b8d2718d3c005aa76
[
https://issues.apache.org/jira/browse/FLINK-18953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180917#comment-17180917
]
Hequn Cheng commented on FLINK-18953:
-
Resolved in 1.12.0 via 8f7e40c9f77f822ff23265
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180427#comment-17180427
]
Hequn Cheng commented on FLINK-18997:
-
Resolved in 1.12.0 via 0522827b27eb6a1351f9a2
[
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
> -
[
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_ma
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 Typ
[
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.
> -
[
https://issues.apache.org/jira/browse/FLINK-18985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180199#comment-17180199
]
Hequn Cheng commented on FLINK-18985:
-
Resolved in 1.12.0 via ebab7f1d9e4ff686dd27ad
[
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.
> -
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: S
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
[
https://issues.apache.org/jira/browse/FLINK-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179439#comment-17179439
]
Hequn Cheng commented on FLINK-18949:
-
Resolved in 1.12.0 via 46e04daa565854e78c3bbc
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179380#comment-17179380
]
Hequn Cheng edited comment on FLINK-18954 at 8/18/20, 6:11 AM:
---
[
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.
> -
[
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 M
[
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.
> --
[
https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179380#comment-17179380
]
Hequn Cheng commented on FLINK-18954:
-
Close this Jira for now since currently MapFu
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-18944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179360#comment-17179360
]
Hequn Cheng commented on FLINK-18944:
-
Resolved in 1.12.0 via f674c7c9c5bf733b77e661
[
https://issues.apache.org/jira/browse/FLINK-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179295#comment-17179295
]
Hequn Cheng commented on FLINK-18886:
-
Resolved in 1.12.0 via 3c61dac47c015a2d3fc5f7
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-18947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179294#comment-17179294
]
Hequn Cheng commented on FLINK-18947:
-
Resolved in 1.12.0 via 917c3d2f294f17ea8031dc
[
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
> -
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-18966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178851#comment-17178851
]
Hequn Cheng commented on FLINK-18966:
-
Resolved in 1.12.0 via 445398cd6f636320092832
[
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
[
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.
[
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"
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178474#comment-17178474
]
Hequn Cheng commented on FLINK-18945:
-
Resolved in 1.12.0 via ecc342904404c272939196
[
https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178449#comment-17178449
]
Hequn Cheng commented on FLINK-18943:
-
Resolved in 1.12.0 via 175038b705f82655a4a082
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178190#comment-17178190
]
Hequn Cheng commented on FLINK-18879:
-
Resolve in 1.12.0 via 1fc400d1f94a10d2f5b227c
[
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
> sourc
[
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 f
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
[
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 Py
[
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
[
https://issues.apache.org/jira/browse/FLINK-18884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177673#comment-17177673
]
Hequn Cheng commented on FLINK-18884:
-
Resolved in 1.12.0 via d3aa4f326d76dd214ca732
[
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
> ---
[
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
>
[
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
> ---
[
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 Pyth
[
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
> -
[
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 DataSt
[
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
>
[
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
> --
[
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
>
[
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
> ---
[
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
>
[
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
> ---
[
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.
[
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.
> --
[
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
>
[
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
>
[
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
> --
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-
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 T
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
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 Typ
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-t
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
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
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 Typ
[
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.
> --
[
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 StreamExecutionEnvironm
[
https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177431#comment-17177431
]
Hequn Cheng commented on FLINK-18878:
-
Resolved in 1.12.0 via 62b20b0c596c77ebf08939
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176260#comment-17176260
]
Hequn Cheng commented on FLINK-1:
-
Resolved in 1.12.0 via 5dadbf312bb103dd3e8e81
[
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.
> -
[
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.
>
[
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.
>
[
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.
> ---
[
https://issues.apache.org/jira/browse/FLINK-18885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176106#comment-17176106
]
Hequn Cheng commented on FLINK-18885:
-
Resolved in 1.12.0 via 82b3669d277b145a06bf81
[
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.
>
[
https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175931#comment-17175931
]
Hequn Cheng commented on FLINK-18863:
-
Resolved in 1.12.0 via 37d7917bc175026cc09f48
[
https://issues.apache.org/jira/browse/FLINK-18866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175490#comment-17175490
]
Hequn Cheng commented on FLINK-18866:
-
Resolved in 1.12.0 via f1e34e659aed9f7bbf7cd7
[
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.
> -
[
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.
>
[
https://issues.apache.org/jira/browse/FLINK-18883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175392#comment-17175392
]
Hequn Cheng commented on FLINK-18883:
-
Resolved in 1.12.0 via 240a1e83406d361a40f411
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175261#comment-17175261
]
Hequn Cheng commented on FLINK-18874:
-
Resolved in 1.12.0 via 8b9193a737e9f32ecad1f0
[
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
> ---
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:
[
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 DataS
[
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: Supp
[
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 StreamExecutionEnvironmen
[
https://issues.apache.org/jira/browse/FLINK-18861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175142#comment-17175142
]
Hequn Cheng commented on FLINK-18861:
-
Resolved in 1.12.0 via 0dad895b03ece20008b1a3
[
https://issues.apache.org/jira/browse/FLINK-18864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175140#comment-17175140
]
Hequn Cheng commented on FLINK-18864:
-
Resolved in 1.12.0 via fa9e4a5ec330998239c9a8
[
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
> --
[
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
> --
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174240#comment-17174240
]
Hequn Cheng commented on FLINK-18766:
-
Resolved in 1.12.0 via b8d2ed787f89c97b47ab2d
1 - 100 of 1204 matches
Mail list logo