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 2997cb5 [minor] Change YarnTestCacheJob to verify retrieved property add dce025e [hotfix][task,test] Add missing test coverage for pretty mailbox exceptions add e6c1b19 [hotfix][task,runtime] Drop unused MailboxExecutor#asExecutor method add 62ce2b7 [hotfix][task,runtime] Make MailboxProcessor implement Closeable add c41e087 [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox No new revisions were added by this update. Summary of changes: .../apache/flink/util/function/FunctionUtils.java | 11 +++++ .../concurrent/FutureTaskWithException.java | 29 ++++++------ .../flink/runtime/concurrent/FutureUtils.java | 4 +- .../streaming/api/operators/MailboxExecutor.java | 51 ++++++++-------------- .../streaming/runtime/tasks/mailbox/Mail.java | 15 ++++--- .../runtime/tasks/mailbox/MailboxExecutorImpl.java | 19 ++++++-- .../runtime/tasks/mailbox/MailboxProcessor.java | 15 ++++--- .../runtime/operators/MailboxOperatorTest.java | 3 +- .../streaming/runtime/tasks/StreamTaskTest.java | 3 +- .../tasks/mailbox/MailboxExecutorImplTest.java | 24 +++++++--- .../runtime/tasks/mailbox/TaskMailboxImplTest.java | 11 +++-- .../tasks/mailbox/TaskMailboxProcessorTest.java | 36 +++++++++++++-- 12 files changed, 136 insertions(+), 85 deletions(-) copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/process/DAGProcessContext.java => flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureTaskWithException.java (57%)