This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ccf4d24ee71 [FLINK-27050][runtime] Removes default RpcSystem instance
new 2560af03f91 [hotfix][tests] Allow retrieval of termination future for
running jobs
new ad2e3afd9df [hotfix][tests] Wait for JobManagerRunner termination
new 8d006224d20 [FLINK-27140][coordination] Write job result in ioExecutor
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/runtime/dispatcher/Dispatcher.java | 100 ++++++++++++---------
.../flink/runtime/dispatcher/MiniDispatcher.java | 43 +++++----
.../flink/runtime/dispatcher/DispatcherTest.java | 12 +--
3 files changed, 89 insertions(+), 66 deletions(-)
