Commits

Commits on Aug 19, 2021

[FLINK-23806][runtime] Avoid StackOverflowException when a large scale job failed to acquire enough slots in time
zhuzhurk
committedAug 19, 2021

Commits on Jul 20, 2021

[FLINK-22677][runtime] AdaptiveScheduler requires partition registration to be completed immediately
zhuzhurk
committedJul 20, 2021
[FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions
zhuzhurk
committedJul 20, 2021

Commits on Mar 15, 2021

[FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy
zhuzhurk
committedMar 15, 2021

Commits on Mar 4, 2021

[FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()
zhuzhurk
committedMar 4, 2021

Commits on Dec 23, 2020

Commits on Dec 17, 2020

Commits on Nov 24, 2020

[FLINK-20285][runtime] LazyFromSourcesSchedulingStrategy checks vertex's right before scheduling it
zhuzhurk
committedNov 24, 2020

Commits on Nov 17, 2020

[FLINK-19806][runtime] Harden DefaultScheduler for concurrent suspending and failing
zhuzhurk
committedNov 17, 2020

Commits on Nov 10, 2020

Commits on Nov 2, 2020

Commits on Oct 27, 2020

[hotifx][runtime] Print root cause of logical slot allocation failures

zhuzhurk
authored and
azagrebin
committedOct 27, 2020
[hotfix][tests] Let SlotSharingExecutionSlotAllocatorTest extend TestLogger

zhuzhurk
authored and
azagrebin
committedOct 27, 2020

Commits on Oct 13, 2020

Commits on Sep 24, 2020

[FLINK-19189][e2e] Let TPC-DS tests run in POINTWISE_EDGES_PIPELINED data exchange mode
zhuzhurk
committedSep 24, 2020
[FLINK-19189][runtime] Enable pipelined region scheduling by default
zhuzhurk
committedSep 24, 2020

Commits on Sep 23, 2020

[FLINK-19286][runtime] Improve region sorting performance
zhuzhurk
committedSep 23, 2020