This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a5611de [FLINK-23621][datastream] Adding mailbox, userClassLoader,
and numberOfParallelSubtasks to Sink#InitContext.
add 81a8a68 [FLINK-21116][tests] Harden
DefaultDispatcherRunnerITCase#leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader.
No new revisions were added by this update.
Summary of changes:
.../dispatcher/TestingJobManagerRunnerFactory.java | 21 ++++++++-------------
.../runner/DefaultDispatcherRunnerITCase.java | 16 ++++++++++++++++
2 files changed, 24 insertions(+), 13 deletions(-)
