adfsdfas#1

Merged

sangyo7 merged 1475 commits intosangyo7:masterfrom

May 18, 2021

This pull request is big! We're only showing the most recent 250 commits

Commits on Apr 21, 2021

[hotfix][docs][python] Fix the invalid url in state.md
dianfu
committed
[hotfix][table-planner-blink] Fix bug for window join: plan is wrong if join condition contains 'IS NOT DISTINCT FROM'

beyond1920
authored and
godfreyhe
committed
[hotfix][docs] Fix the invalid urls in iterations.md
dianfu
committed
[FLINK-16384][table][sql-client] Support 'SHOW CREATE TABLE' statement

fsk119
authored and
wuchong
committed
[FLINK-16384][table][sql-client] Improve implementation of 'SHOW CREATE TABLE' statement.

LadyForest
authored and
wuchong
committed
[hotfix][docs][python] Add missing pages for PyFlink documentation
dianfu
committed
[FLINK-22348][python] Fix DataStream.execute_and_collect which doesn't declare managed memory for Python operators

HuangXingBo
authored and
dianfu
committed
[FLINK-22350][python][docs] Add documentation for user-defined window in Python DataStream API

HuangXingBo
authored and
dianfu
committed
[FLINK-22354][table-planner] Fix the timestamp function return value precision isn't matching with declared DataType

leonardBang
authored and
wuchong
committed
[FLINK-22354][table] Remove the strict precision check of time attribute field

leonardBang
authored and
wuchong
committed
[FLINK-22354][table] Fix TIME field display in sql-client

leonardBang
authored and
wuchong
committed
[hotfix] Set default value of resource-stabilization-timeout to 10s
tillrohrmann
committed
[FLINK-22345][coordination] Remove incorrect assertion in scheduler
StephanEwen
committed

Commits on Apr 22, 2021

Commits on Apr 23, 2021

Commits on Apr 24, 2021

[FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled #8321 (#8321)
wuchong
authored

Commits on Apr 25, 2021

Commits on Apr 26, 2021

Commits on Apr 27, 2021

Commits on Apr 28, 2021

Commits on Apr 29, 2021

[FLINK-22304][table] Refactor some interfaces for TVF based window to improve the extendability

shuo.cs
authored and
wuchong
committed
[hotfix][python][docs] Fix python.archives docs

t0t07
authored and
dianfu
committed
[FLINK-20086][python][docs] Add documentation about how to override open() in UserDefinedFunction to load resources

t0t07
authored and
dianfu
committed
[FLINK-22438][metrics] Add numRecordsOut metric for Async IO

zhangzhengqi3
authored and
tillrohrmann
committed
[FLINK-22373][docs] Add Flink 1.13 release notes
dawidwys
committed
[FLINK-22495][docs] Add Reactive Mode section to K8s
rmetzger
committed
[FLINK-21967] Add documentation on the operation of blocking shuffle

gaoyunhaii
authored and
guoweiM
committed
[FLINK-22232][tests] Add UnalignedCheckpointsStressITCase
pnowojski
committed
[FLINK-22232][network] Add task name to output recovery tracing.

Arvid Heise
authored and
pnowojski
committed
[FLINK-22232][network] Add task name to persist tracing.

Arvid Heise
authored and
pnowojski
committed
[FLINK-22232][network] More logging of network stack.

Arvid Heise
authored and
pnowojski
committed
[FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

MaChengLong
authored and
twalthr
committed
[FLINK-22426][table] Fix several shortcomings that prevent schema expressions
twalthr
committed
[FLINK-22493] Increase test stability in AdaptiveSchedulerITCase.
rmetzger
committed

Commits on May 1, 2021

Commits on May 2, 2021

[hotfix][python][docs] Correct a few invalid links and typos in PyFlink documentation
dianfu
committed

Commits on May 3, 2021

Commits on May 4, 2021

Commits on May 5, 2021

[FLINK-22379][runtime] CheckpointCoordinator checks the state of all subtasks before triggering the checkpoint

akalash
authored and
rkhachatryan
committed
[FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

lindong28
authored and
dawidwys
committed
[FLINK-22442][CEP] Using scala api to change the TimeCharacteristic of the PatternStream is invalid

chennuo
authored and
dawidwys
committed
[FLINK-22573][datastream] Fix AsyncIO calls timeout on completed element.

Arvid Heise
authored and
AHeise
committed
[FLINK-22573][datastream] Fix AsyncIO calls timeout on completed element.

Arvid Heise
authored and
AHeise
committed

Commits on May 6, 2021

Commits on May 7, 2021

Commits on May 8, 2021

Commits on May 10, 2021

Commits on May 11, 2021

Commits on May 12, 2021

Commits on May 13, 2021

Commits on May 14, 2021

Commits on May 15, 2021

[FLINK-22511][python] Fix the bug of non-composite result type in Python TableAggregateFunction
HuangXingBo
committed

Commits on May 16, 2021

[[hotfix][docs] Changed argument for toDataStream to Table
mans2singh
authored

Commits on May 17, 2021

Commits on May 18, 2021