Commits

Commits on Apr 19, 2021

[FLINK-22276][runtime] Fixes the concurrency issue

XComp
authored and
tillrohrmann
committedApr 19, 2021
[hotfix][test] Cleans up unused local variable

XComp
authored and
tillrohrmann
committedApr 19, 2021
[hotfix][runtime] Wrong annotation was used

XComp
authored and
tillrohrmann
committedApr 19, 2021
[FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contains 'IS NOT DISTINCT FROM'

beyond1920
authored and
godfreyhe
committedApr 19, 2021
[FLINK-22208][build] Bump snappy-java to 1.1.8.3
zentol
committedApr 19, 2021
[hotfix][python] Fix typo in BeamDataStreamPythonFunctionRunner

RocMarshal
authored and
dianfu
committedApr 19, 2021
[FLINK-22340][runtime] Make ThresholdMeter thread safe.
xintongsong
committedApr 19, 2021
[hotfix][runtime] Minor clean-up in ThreasholdMeter.
xintongsong
committedApr 19, 2021
[FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark
fsk119
committedApr 19, 2021
[FLINK-22339][python] Fix some encoding exceptions were not thrown in cython coders
HuangXingBo
committedApr 19, 2021
[FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

lindong28
authored and
dawidwys
committedApr 19, 2021
[FLINK-21798][test] Fail on double-freeing memory segment for CI tests.
xintongsong
committedApr 19, 2021
[hotfix][docs] Removed reference to "fold" function in "Windows" page (apache#15574 )
mans2singh
committedApr 19, 2021
[FLINK-22099][table-planner-blink] Fix bug about throwing ArrayIndexOutOfBoundsException when window join deals with semi/anti queries

beyond1920
authored and
godfreyhe
committedApr 19, 2021
[FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

fsk119
authored and
wuchong
committedApr 19, 2021
[FLINK-22327][python] Makes sure that bundleStarted is set to false when it throws exception in finishBundle
dianfu
committedApr 19, 2021

Commits on Apr 18, 2021

Update version to 1.14-SNAPSHOT
guoweiM
committedApr 18, 2021
[FLINK-22303][table-planner-blink] FlinkRelMdFilteredColumnInterval should remapping the columnIndex of the inputRel otherwise may cause IllegalArgumentException or get incorrectly metadata

lincoln-lil
authored and
godfreyhe
committedApr 18, 2021
[FLINK-21627][table-planner-blink] The digest of Sink should consider table hints
godfreyhe
committedApr 18, 2021
[FLINK-21627][table-planner-blink] The digest of TableScan should consider table hints
godfreyhe
committedApr 18, 2021
[FLINK-22310][table-planner-blink] Fix the incorrect deserialization result of LogicalWindowJsonDeserializer
godfreyhe
committedApr 18, 2021
[FLINK-22307][network] Increase the default value of data writing cache size (not configurable) for sort-merge blocking shuffle

wsry
authored and
guoweiM
committedApr 18, 2021
[FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

wsry
authored and
guoweiM
committedApr 18, 2021

Commits on Apr 17, 2021

Commits on Apr 16, 2021

[hotfix][coordination] Add safety guard against uncaught exceptions for Future dependent lambdas
StephanEwen
committedApr 16, 2021
[FLINK-21996][coordination] Ensure exactly-once guarantees for OperatorEvent RPCs
StephanEwen
committedApr 16, 2021
[FLINK-22276][runtime] Adds workaround for FLINK-22276

XComp
authored and
tillrohrmann
committedApr 16, 2021
Revert "[FLINK-22249][FLINK-22248] Temporarily disable JobMasterStopWithSavepointITCase"
dawidwys
committedApr 16, 2021
[FLINK-22248][tests] Improve JobMasterStopWithSavepoint#waitForJob to wait for all tasks running
dawidwys
committedApr 16, 2021
[hotfix][tests] Cancel all running jobs after each test in AbstractTestBase
dawidwys
committedApr 16, 2021
[FLINK-22248][tests] Remove timeouts from JobMasterStopWithSavepointITCase
dawidwys
committedApr 16, 2021
[FLINK-22249][tests] Add FAILLING to an assertion in JobMasterStopWithSavepointITCase
dawidwys
committedApr 16, 2021