Commits

History for

Commits on Feb 23, 2021

[FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'
WeiZhong94
committedFeb 23, 2021
[FLINK-20994][python] Add public method to create TableEnvironment in PyFlink
WeiZhong94
committedFeb 23, 2021

Commits on Feb 22, 2021

[FLINK-21412][python] Fix Decimal type which doesn't work in UDAF and expression DSL
dianfu
committedFeb 22, 2021

Commits on Feb 12, 2021

[FLINK-21295][table-api] Support 'useModules' and 'listFullModules' in TableEnvironment and ModuleManager
LadyForest
committedFeb 12, 2021

Commits on Feb 10, 2021

[FLINK-21193][release] Update python Sphynx build
sjwiesman
committedFeb 10, 2021

Commits on Feb 7, 2021

[FLINK-21238][python] Support to close PythonFunctionFactory manually

dianfu
authored and
WeiZhong94
committedFeb 7, 2021
[FLINK-21208][python] Make Arrow Coder serialize schema info in every batch
HuangXingBo
committedFeb 7, 2021

Commits on Feb 4, 2021

[FLINK-21149][table-common] Remove deprecated CatalogBaseTable.getProperties()
twalthr
committedFeb 4, 2021

Commits on Feb 3, 2021

[FLINK-19360][scripts] Support spaces in '${JAVA_HOME}'
raghavgautam
committedFeb 3, 2021

Commits on Feb 1, 2021

[FLINK-21216][python] Limit the numpy version < 1.20.0 (apache#14825 )
HuangXingBo
committedFeb 1, 2021

Commits on Jan 31, 2021

[FLINK-21112][python] Expose MapState to users
dianfu
committedJan 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 Jan 29, 2021

[FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration
dianfu
committedJan 29, 2021

Commits on Jan 27, 2021

[FLINK-21140][python] Extract zip file dependencies before adding to PYTHONPATH
dianfu
committedJan 27, 2021

Commits on Jan 25, 2021

[FLINK-21020][build] Bump Jackson to 2.12.1

HuangXingBo
authored and
zentol
committedJan 25, 2021

Commits on Jan 20, 2021

[FLINK-21019][python] Bump Netty to 4.1.46

HuangXingBo
authored and
zentol
committedJan 20, 2021
Revert "[FLINK-20946][python] Optimize ValueState implementation"
dianfu
committedJan 20, 2021
[FLINK-20946][python] Optimize ValueState implementation

HuangXingBo
authored and
dianfu
committedJan 20, 2021

Commits on Jan 19, 2021

[FLINK-20971][table-api-java] Support calling SQL expressions in Table API
twalthr
committedJan 19, 2021
[FLINK-20963][python] Update examples to use the latest recommended API (apache#14673 )
lometheus
committedJan 19, 2021

Commits on Jan 18, 2021

[FLINK-20933][python] Fix the Python operators of Python DataStream API doesn't use managed memory when mixed use with Python Table API

HuangXingBo
authored and
dianfu
committedJan 18, 2021

Commits on Jan 14, 2021

[FLINK-20921][python] Fixes the Date/Time/Timestamp type in Python DataStream API

HuangXingBo
authored and
dianfu
committedJan 14, 2021
[FLINK-20954][python] Support state cache between bundles (apache#14628 )
HuangXingBo
committedJan 14, 2021

Commits on Jan 11, 2021

[FLINK-20619][runtime] Remove unused InputDependencyConstraint

XComp
authored and
rmetzger
committedJan 11, 2021

Commits on Jan 9, 2021

[FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.
xintongsong
committedJan 9, 2021

Commits on Jan 8, 2021

[FLINK-20522][table] Add built-in IFNULL function
twalthr
committedJan 8, 2021

Commits on Jan 7, 2021

[FLINK-18090] Update tests for new Row.toString
twalthr
committedJan 7, 2021

Commits on Jan 5, 2021

[FLINK-19981][core][table] Add name-based field mode for Row
twalthr
committedJan 5, 2021

Commits on Jan 2, 2021

[FLINK-20828][python] Fix some aggregate and flat_aggregate tests failed in py35 (apache#14540 )
HuangXingBo
committedJan 2, 2021

Commits on Dec 31, 2020

[FLINK-20769][python] Support minibatch to optimize Python UDAF

HuangXingBo
authored and
dianfu
committedDec 31, 2020

Commits on Dec 30, 2020

[FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

HuangXingBo
authored and
dianfu
committedDec 30, 2020

Commits on Dec 28, 2020

[FLINK-20651] Format code with Spotless/google-java-format

Rufus Refactor
authored and
zentol
committedDec 28, 2020
[hotfix] Fix incorrect license headers

aljoscha
authored and
zentol
committedDec 28, 2020
[FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept table function directly

HuangXingBo
authored and
dianfu
committedDec 28, 2020

Commits on Dec 25, 2020

[FLINK-20702][python] Support map operation chained together in Python Table API

HuangXingBo
authored and
dianfu
committedDec 25, 2020