This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 73cdd3d [FLINK-18090] Update tests for new Row.toString
add 2931750 [FLINK-20868][task][metrics] Pause the idle/back pressure
timers during processing mailbox actions
add 93a88a5 [hotfix][test] Use varargs in StreamTaskTest#setupEnvironment
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/runtime/tasks/StreamTask.java | 3 +-
.../tasks/mailbox/MailboxDefaultAction.java | 11 ++
.../runtime/tasks/mailbox/MailboxProcessor.java | 88 ++++++++---
.../streaming/runtime/tasks/StreamTaskTest.java | 169 ++++++++++++++-------
.../tasks/mailbox/MailboxExecutorImplTest.java | 3 +-
5 files changed, 195 insertions(+), 79 deletions(-)
