Commits

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
[hotfix][docs] Fix config doc structure

Arvid Heise
authored and
AHeise
committedApr 16, 2021
[FLINK-22290][checkpointing] Adding alignment timeout and force unaligned checkpoint options to PyFlink and polished Java API.

Arvid Heise
authored and
AHeise
committedApr 16, 2021
[FLINK-22290][checkpointing] Use duration for alignment timeout.

Arvid Heise
authored and
AHeise
committedApr 16, 2021
[FLINK-20613][table] Update TableResult.collect() to the new type system
twalthr
committedApr 16, 2021
[FLINK-20613][table] Introduce a legacy to non-legacy data type transformation
twalthr
committedApr 16, 2021
[FLINK-20613][table-planner-blink] Support unidirectional ExternalSerializer
twalthr
committedApr 16, 2021
[hotfix][table-api-java] Improve built-in functions as parameters of user-defined functions
twalthr
committedApr 16, 2021
[hotfix][tests] Simplify and harden CoordinatorEventsExactlyOnceITCase
StephanEwen
committedApr 16, 2021
[hotfix][tests] Minor debuggability improvements to CoordinatedSourceRescaleITCase
StephanEwen
committedApr 16, 2021
[hotfix][coordination] Remove unnecessary null check
StephanEwen
committedApr 16, 2021
[hotfix][coordination] Reduce lambda nesting for action on CompletableFuture
StephanEwen
committedApr 16, 2021
[hotfix][coordination] Make failed event valve shutting smoother.
StephanEwen
committedApr 16, 2021
[FLINK-18071][coordination] (part 5) Communication from Coordinators to Tasks happens through gateways that are scoped to a single execution attempt.
StephanEwen
committedApr 16, 2021
[FLINK-18071][coordination] (part 4) Add to Execution a future for states INITIALIZING/RUNNING
StephanEwen
committedApr 16, 2021
[FLINK-18071][coordination] (part 3) Adjust OperatorEventValve to accept self-contained "send actions".
StephanEwen
committedApr 16, 2021
[FLINK-18071][coordination] (part 2) OperatorCoordinatorHolder does not implement OperatorCoordinator interface any more
StephanEwen
committedApr 16, 2021