Shuiqiang Chen created FLINK-30817:
--
Summary: ClassCastException in
TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown
Key: FLINK-30817
URL:
Shuiqiang Chen created FLINK-29146:
--
Summary: User set job configuration can not be retirieved from
JobGraph and ExecutionGraph
Key: FLINK-29146
URL: https://issues.apache.org/jira/browse/FLINK-29146
Shuiqiang Chen created FLINK-28119:
--
Summary: Update the document for Contribute Documentation
Key: FLINK-28119
URL: https://issues.apache.org/jira/browse/FLINK-28119
Project: Flink
Issue
Shuiqiang Chen created FLINK-27881:
--
Summary: The key(String) in PulsarMessageBuilder returns null
Key: FLINK-27881
URL: https://issues.apache.org/jira/browse/FLINK-27881
Project: Flink
Shuiqiang Chen created FLINK-21966:
--
Summary: Support Kinesis connector in Python DataStream API.
Key: FLINK-21966
URL: https://issues.apache.org/jira/browse/FLINK-21966
Project: Flink
Shuiqiang Chen created FLINK-21113:
--
Summary: Add State access API for KeyedStream RuntimeContext.
Key: FLINK-21113
URL: https://issues.apache.org/jira/browse/FLINK-21113
Project: Flink
Shuiqiang Chen created FLINK-21112:
--
Summary: Add ValueState/ListState/MapState and corresponding
StateDescriptors for Python DataStream API
Key: FLINK-21112
URL:
Shuiqiang Chen created FLINK-2:
--
Summary: Support State access in Python DataStream API
Key: FLINK-2
URL: https://issues.apache.org/jira/browse/FLINK-2
Project: Flink
Issue
Shuiqiang Chen created FLINK-20720:
--
Summary: Add documentation for ProcessFunction in Python
DataStream API
Key: FLINK-20720
URL: https://issues.apache.org/jira/browse/FLINK-20720
Project: Flink
Shuiqiang Chen created FLINK-20647:
--
Summary: Use yield to generate output datas in ProcessFunction for
Python DataStream
Key: FLINK-20647
URL: https://issues.apache.org/jira/browse/FLINK-20647
Shuiqiang Chen created FLINK-20621:
--
Summary: Refactor the TypeInformation implementation in Python
DataStream API
Key: FLINK-20621
URL: https://issues.apache.org/jira/browse/FLINK-20621
Project:
Shuiqiang Chen created FLINK-20365:
--
Summary: The native k8s cluster could not be unregistered when
executing Python DataStream application attachedly.
Key: FLINK-20365
URL:
Shuiqiang Chen created FLINK-20275:
--
Summary: The path delimiter for add_jars and add_classpaths in
Python StreamExecutionEnvironment should be ;
Key: FLINK-20275
URL:
Shuiqiang Chen created FLINK-20164:
--
Summary: Add docs for ProcessFunction and Timer for Python
DataStream API.
Key: FLINK-20164
URL: https://issues.apache.org/jira/browse/FLINK-20164
Project: Flink
Shuiqiang Chen created FLINK-20137:
--
Summary: User cannot obtain the timestamp of current processing
element in the ProcessFunction of Python DataStream API
Key: FLINK-20137
URL:
Shuiqiang Chen created FLINK-20016:
--
Summary: Support TimestampAssigner and WatermarkGenerator for
Python DataStream API.
Key: FLINK-20016
URL: https://issues.apache.org/jira/browse/FLINK-20016
Shuiqiang Chen created FLINK-19821:
--
Summary: Add ProcessFunction and timer access for Python
DataStream API.
Key: FLINK-19821
URL: https://issues.apache.org/jira/browse/FLINK-19821
Project: Flink
Shuiqiang Chen created FLINK-19145:
--
Summary: Add PyFlink-walkthrough in Flink playground.
Key: FLINK-19145
URL: https://issues.apache.org/jira/browse/FLINK-19145
Project: Flink
Issue Type:
Shuiqiang Chen created FLINK-19134:
--
Summary: Fix the converter of array coder for Python DataStream
API.
Key: FLINK-19134
URL: https://issues.apache.org/jira/browse/FLINK-19134
Project: Flink
Shuiqiang Chen created FLINK-19097:
--
Summary: Support add_jar() for Python DataStream API
Key: FLINK-19097
URL: https://issues.apache.org/jira/browse/FLINK-19097
Project: Flink
Issue Type:
Shuiqiang Chen created FLINK-19041:
--
Summary: Add dependency management for ConnectedStream in Python
DataStream API.
Key: FLINK-19041
URL: https://issues.apache.org/jira/browse/FLINK-19041
Project:
Shuiqiang Chen created FLINK-18950:
--
Summary: Add documentation for Operations in Python DataStream
API.
Key: FLINK-18950
URL: https://issues.apache.org/jira/browse/FLINK-18950
Project: Flink
Shuiqiang Chen created FLINK-18951:
--
Summary: Add documentation for Configurations in Python DataStream
API.
Key: FLINK-18951
URL: https://issues.apache.org/jira/browse/FLINK-18951
Project: Flink
Shuiqiang Chen created FLINK-18946:
--
Summary: Support Cassandra connector for Python DataStream API
Key: FLINK-18946
URL: https://issues.apache.org/jira/browse/FLINK-18946
Project: Flink
Shuiqiang Chen created FLINK-18944:
--
Summary: Support JDBC connector for Python DataStream API
Key: FLINK-18944
URL: https://issues.apache.org/jira/browse/FLINK-18944
Project: Flink
Issue
Shuiqiang Chen created FLINK-1:
--
Summary: Add ElasticSearch connector for Python DataStream API
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Project: Flink
Shuiqiang Chen created FLINK-18887:
--
Summary: Add ElasticSearch connector for Python DataStream API
Key: FLINK-18887
URL: https://issues.apache.org/jira/browse/FLINK-18887
Project: Flink
Shuiqiang Chen created FLINK-18886:
--
Summary: Support Kafka connectors for Python DataStream API
Key: FLINK-18886
URL: https://issues.apache.org/jira/browse/FLINK-18886
Project: Flink
Issue
Shuiqiang Chen created FLINK-18885:
--
Summary: Add partitioning interfaces for Python DataStream.
Key: FLINK-18885
URL: https://issues.apache.org/jira/browse/FLINK-18885
Project: Flink
Issue
Shuiqiang Chen created FLINK-18884:
--
Summary: Add chaining strategy and slot sharing group interfaces
for DataStream
Key: FLINK-18884
URL: https://issues.apache.org/jira/browse/FLINK-18884
Project:
Shuiqiang Chen created FLINK-18879:
--
Summary: Support Row Serialization and Deserialization schemas for
DataStream source/sink
Key: FLINK-18879
URL: https://issues.apache.org/jira/browse/FLINK-18879
Shuiqiang Chen created FLINK-18878:
--
Summary: Support dependency management for Python
StreamExecutionEnvironment.
Key: FLINK-18878
URL: https://issues.apache.org/jira/browse/FLINK-18878
Project:
Shuiqiang Chen created FLINK-18874:
--
Summary: Support conversion between Table and DataStream
Key: FLINK-18874
URL: https://issues.apache.org/jira/browse/FLINK-18874
Project: Flink
Issue
Shuiqiang Chen created FLINK-18866:
--
Summary: Support filter() interface for Python DataStream API.
Key: FLINK-18866
URL: https://issues.apache.org/jira/browse/FLINK-18866
Project: Flink
Shuiqiang Chen created FLINK-18864:
--
Summary: Support key_by() operation for Python DataStream API
Key: FLINK-18864
URL: https://issues.apache.org/jira/browse/FLINK-18864
Project: Flink
Shuiqiang Chen created FLINK-18863:
--
Summary: Support print() and write_as_text() interface for Python
DataStream API.
Key: FLINK-18863
URL: https://issues.apache.org/jira/browse/FLINK-18863
Shuiqiang Chen created FLINK-18861:
--
Summary: Support add_source() to get a DataStream for Python
StreamExecutionEnvironment
Key: FLINK-18861
URL: https://issues.apache.org/jira/browse/FLINK-18861
37 matches
Mail list logo
