This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5c772f0 [hotfix] Add timeout to bash scripts waiting for an event
add 85879bf [FLINK-21362][coordination] Move State.onEnter() logic into
constructor
No new revisions were added by this update.
Summary of changes:
.../scheduler/adaptive/AdaptiveScheduler.java | 39 +++++---
.../runtime/scheduler/adaptive/Canceling.java | 38 +++++++-
.../flink/runtime/scheduler/adaptive/Created.java | 19 ++++
.../runtime/scheduler/adaptive/Executing.java | 42 ++++++++-
.../flink/runtime/scheduler/adaptive/Failing.java | 45 +++++++--
.../flink/runtime/scheduler/adaptive/Finished.java | 27 ++++--
.../runtime/scheduler/adaptive/Restarting.java | 42 ++++++++-
.../flink/runtime/scheduler/adaptive/State.java | 3 -
.../{ResourceConsumer.java => StateFactory.java} | 12 ++-
.../scheduler/adaptive/WaitingForResources.java | 39 ++++++--
.../adaptive/AdaptiveSchedulerSimpleITCase.java | 9 +-
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 105 ++++++++++++---------
.../runtime/scheduler/adaptive/CancelingTest.java | 11 +--
.../runtime/scheduler/adaptive/ExecutingTest.java | 19 ++--
.../runtime/scheduler/adaptive/FailingTest.java | 12 +--
.../runtime/scheduler/adaptive/FinishedTest.java | 9 +-
.../runtime/scheduler/adaptive/RestartingTest.java | 11 ++-
.../adaptive/WaitingForResourcesTest.java | 47 +++++----
18 files changed, 378 insertions(+), 151 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/{ResourceConsumer.java
=> StateFactory.java} (79%)
