Commits

Commits on Jul 24, 2023

[FLINK-32654][configuration] Deprecate ExecutionConfig#canEqual(obj)
zhuzhurk
committedJul 24, 2023

Commits on Jan 31, 2023

[FLINK-30828][table-planner] Let SortAggITCase#testLeadLag run in ALL_EXCHANGES_PIPELINED mode
zhuzhurk
committedJan 31, 2023

Commits on Jan 30, 2023

Commits on Aug 23, 2022

[FLINK-28139][docs] Add documentation for speculative execution
zhuzhurk
committedAug 23, 2022

Commits on Aug 15, 2022

[FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase
zhuzhurk
committedAug 15, 2022

Commits on Aug 3, 2022

[FLINK-28771][runtime] Assign speculative execution attempt with correct CREATED timestamp
zhuzhurk
committedAug 3, 2022

Commits on Jul 26, 2022

[FLINK-28610][runtime] Enable speculative execution for sources
zhuzhurk
committedJul 26, 2022

Commits on Jul 25, 2022

[FLINK-28585][runtime] Ensure all the concurrent executions of SpeculativeExecutionVertex to share the same input splits
zhuzhurk
committedJul 25, 2022

Commits on Jul 22, 2022

Commits on Jul 20, 2022

Commits on Jul 13, 2022

Commits on Jul 11, 2022

[FLINK-28402][runtime] Create FailureHandlingResultSnapshot with the truly failed execution
zhuzhurk
committedJul 11, 2022
[hotfix] Migrate failure handling tests to JUnit5
zhuzhurk
committedJul 11, 2022

Commits on Jul 6, 2022

[FLINK-28392][runtime] DefaultExecutionDeployer avoid retrieving executions from ExecutionGraph#currentExecutions
zhuzhurk
committedJul 6, 2022

Commits on Jul 1, 2022

Commits on Jun 28, 2022

[FLINK-28258][runtime] Introduce ExecutionHistory to host historical executions for each execution vertex
zhuzhurk
committedJun 28, 2022