Commits

Commits on Jan 31, 2021

[FLINK-21112][python] Add ValueState/ListState/MapState and corresponding StateDescriptors for Python DataStream API.

shuiqiangchen
authored and
dianfu
committedJan 31, 2021

Commits on Dec 23, 2020

[FLINK-20621][python] Improve the TypeInformation implementation in Python DataStream API

shuiqiangchen
authored and
dianfu
committedDec 23, 2020

Commits on Dec 18, 2020

[FLINK-20647][python] Use yield to generate output data in ProcessFunction of Python DataStream API

shuiqiangchen
authored and
dianfu
committedDec 18, 2020

Commits on Dec 17, 2020

[FLINK-20601][docs][python] Rework PyFlink CLI documentation.

shuiqiangchen
authored and
dianfu
committedDec 17, 2020

Commits on Dec 3, 2020

[FLINK-20467][python][docs] Fix the example in Python DataStream API documentation

shuiqiangchen
authored and
dianfu
committedDec 3, 2020

Commits on Nov 26, 2020

[FLINK-20365][python] The native k8s cluster could not be unregistered when executing Python DataStream jobs in attach mode

shuiqiangchen
authored and
dianfu
committedNov 26, 2020

Commits on Nov 24, 2020

[FLINK-20278][Python] Throw a meaningful exception if the Python DataStream API job executes in batch mode

shuiqiangchen
authored and
dianfu
committedNov 24, 2020

Commits on Nov 23, 2020

[FLINK-20275][python] Fix the delimiter of the dependencies of Python DataStream API

shuiqiangchen
authored and
dianfu
committedNov 23, 2020

Commits on Nov 19, 2020

[FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API

shuiqiangchen
authored and
dianfu
committedNov 19, 2020
[FLINK-200137][python] Handle the timestamp of elements properly in Python DataStream API

shuiqiangchen
authored and
dianfu
committedNov 19, 2020

Commits on Nov 9, 2020

[FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

shuiqiangchen
authored and
dianfu
committedNov 9, 2020

Commits on Nov 5, 2020

[FLINK-19821][python] Add ProcessFunction and timer access in Python DataStream API

shuiqiangchen
authored and
dianfu
committedNov 5, 2020

Commits on Oct 29, 2020

[FLINK-19770][python][tests] Extract PythonProgramOptionTest#testConfigurePythonExecution into an ITCase

shuiqiangchen
authored and
dianfu
committedOct 29, 2020

Commits on Oct 21, 2020

[FLINK-18415][python] Support TableResult#collect in the Python Table API to align with the Java Table API

shuiqiangchen
authored and
dianfu
committedOct 21, 2020

Commits on Oct 13, 2020

[FLINK-19484][python][tests] Set longer timeout for jobmanager pod availability in PyFlink kubernetes application test (apache#13607 )
shuiqiangchen
committedOct 13, 2020

Commits on Sep 30, 2020

[FLINK-17480][kubernetes][python] Support running PyFlink on Kubernetes

shuiqiangchen
authored and
dianfu
committedSep 30, 2020

Commits on Sep 25, 2020

[FLINK-19134][python] Introduce BasicArrayTypeInfo and PrimitiveArrayTypeInfo for Python DataStream API

shuiqiangchen
authored and
dianfu
committedSep 25, 2020

Commits on Sep 22, 2020

[FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API

shuiqiangchen
authored and
dianfu
committedSep 22, 2020

Commits on Sep 10, 2020

[FLINK-18951][python][docs] Add documentation for dependency management for Python DataStream API.

shuiqiangchen
authored and
dianfu
committedSep 10, 2020
[FLINK-18951][python][docs-zh] Translate Python Table API dependency management documentation into chinese.

shuiqiangchen
authored and
dianfu
committedSep 10, 2020

Commits on Sep 7, 2020

[FLINK-19097][python] Support add_jars() in Python StreamExecutionEnvironment.

shuiqiangchen
authored and
dianfu
committedSep 7, 2020

Commits on Sep 5, 2020

[FLINK-18598][python][docs] Add documentation on how to wait for the job execution to finish when using asynchronous APIs

shuiqiangchen
authored and
dianfu
committedSep 5, 2020

Commits on Aug 26, 2020

[FLINK-19041][python] Add dependency management for ConnectedStream in Python DataStream API. (apache#13236 )
shuiqiangchen
committedAug 26, 2020

Commits on Aug 24, 2020

[FLINK-18948][python][e2e] Add E2E test for Python DataStream API

shuiqiangchen
authored and
dianfu
committedAug 24, 2020

Commits on Aug 18, 2020

Commits on Aug 15, 2020

[FLINK-18879][python] Support Row Serialization and Deserialization schemas for Python DataStream API. (apache#13150 )
shuiqiangchen
committedAug 15, 2020

Commits on Aug 14, 2020

Commits on Aug 12, 2020

Commits on Aug 11, 2020