[flink] branch master updated (6d865e2 -> 809533e)

[pn...@apache.org]

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 6d865e2  [FLINK-14639][metrics][docs] Fix methods signature
     add edeec8d  [hotfix][runtime] Replace all occurrences of letter to mail to unify wording of variables and documentation.
     add bf7a402  [hotfix][runtime] Replace MailboxStateException with IllegalStateException.
     add 14fde46  [hotfix][runtime] Added TaskMailbox#drain and using it to implement MailboxProcessor. Also changed return types of TaskMailbox#close to Mail for unification.
     add f4e78ef  [hotfix][runtime] Simplified and tweaked TaskMailboxImpl.
     add 05c6915  [FLINK-14304][runtime] Adding batch capabilities to TaskMailbox, moved mailbox thread ownership into mailbox to sharpen the threading model, and simplified hierarchy.
     add 7111507  [hotfix][runtime/core] Cleaning up MailProcessor and adding utility method to WrappingRuntimeException.
     add f62d98e  [hotfix][runtime] Consolidating javadoc and package structure.
     add 809533e  [hotfix][runtime] Moving interfaces closely related to mailbox default action into MailboxDefaultAction. Renaming DefaultActionContext to MailboxDefaultAction.Controller.

No new revisions were added by this update.

Summary of changes:
 .../flink/util/WrappingRuntimeException.java       |  13 ++
 .../flink/state/api/output/BoundedStreamTask.java  |   6 +-
 .../operators}/MailboxExecutor.java                |  72 +++++--
 .../api/operators/StreamOperatorFactoryUtil.java   |   3 +-
 .../api/operators/YieldingOperatorFactory.java     |   2 -
 .../api/operators/async/AsyncWaitOperator.java     |   2 +-
 .../operators/async/AsyncWaitOperatorFactory.java  |   2 +-
 .../streaming/runtime/tasks/OperatorChain.java     |   2 +-
 .../streaming/runtime/tasks/SourceStreamTask.java  |   6 +-
 .../runtime/tasks/StreamIterationHead.java         |   6 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |  23 +--
 .../streaming/runtime/tasks/mailbox/Mailbox.java   |  69 -------
 .../tasks/mailbox/MailboxDefaultAction.java        |  68 +++++++
 .../{execution => }/MailboxExecutorFactory.java    |   8 +-
 .../runtime/tasks/mailbox/MailboxExecutorImpl.java |  84 ++++++++
 .../mailbox/{execution => }/MailboxProcessor.java  | 161 +++++++--------
 .../tasks/mailbox/MailboxStateException.java       |  41 ----
 .../runtime/tasks/mailbox/TaskMailbox.java         | 163 +++++++++++++--
 .../runtime/tasks/mailbox/TaskMailboxImpl.java     | 221 +++++++++++++--------
 .../mailbox/execution/DefaultActionContext.java    |  38 ----
 .../mailbox/execution/MailboxDefaultAction.java    |  37 ----
 .../mailbox/execution/MailboxExecutorImpl.java     | 126 ------------
 .../execution/SuspendedMailboxDefaultAction.java   |  30 ---
 .../runtime/operators/MailboxOperatorTest.java     | 160 +++++++++++++++
 .../operators/StreamTaskOperatorTimerTest.java     |   2 +-
 .../tasks/StreamTaskSelectiveReadingTest.java      |   6 +-
 .../runtime/tasks/StreamTaskTerminationTest.java   |   6 +-
 .../streaming/runtime/tasks/StreamTaskTest.java    |  46 ++---
 .../runtime/tasks/SynchronousCheckpointITCase.java |   8 +-
 .../runtime/tasks/SynchronousCheckpointTest.java   |   6 +-
 .../tasks/TaskCheckpointingBehaviourTest.java      |   6 +-
 .../{execution => }/MailboxExecutorImplTest.java   |  24 +--
 .../runtime/tasks/mailbox/TaskMailboxImplTest.java | 116 ++++++++---
 .../{execution => }/TaskMailboxProcessorTest.java  |  94 ++++++---
 .../flink/streaming/util/MockStreamTask.java       |   6 +-
 .../jobmaster/JobMasterStopWithSavepointIT.java    |  10 +-
 36 files changed, 979 insertions(+), 694 deletions(-)
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/{runtime/tasks/mailbox/execution => api/operators}/MailboxExecutor.java (77%)
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/Mailbox.java
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxDefaultAction.java
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/{execution => }/MailboxExecutorFactory.java (84%)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutorImpl.java
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/{execution => }/MailboxProcessor.java (55%)
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxStateException.java
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/DefaultActionContext.java
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxDefaultAction.java
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorImpl.java
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/SuspendedMailboxDefaultAction.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/MailboxOperatorTest.java
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/{execution => }/MailboxExecutorImplTest.java (86%)
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/{execution => }/TaskMailboxProcessorTest.java (69%)