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%)
