This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3059a2f [FLINK-13133] [pubsub] Fix small error in PubSub documentation relating to PubSubSink serializer and emulator settings new acfbc83 [hotfix] Remove dangerous waiting methods from mailbox new 5b24aa0 [FLINK-12804] Introduce mailbox-based ExecutorService new 6cf98b6 [FLINK-12804] Change mailbox implementation from bounded to unbounded The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../flink/state/api/output/BoundedStreamTask.java | 3 +- .../flink/runtime/concurrent/FutureUtils.java | 26 ++ .../streaming/runtime/tasks/SourceStreamTask.java | 66 ++--- .../runtime/tasks/StreamIterationHead.java | 3 +- .../flink/streaming/runtime/tasks/StreamTask.java | 94 ++----- .../streaming/runtime/tasks/mailbox/Mailbox.java | 49 +++- .../runtime/tasks/mailbox/MailboxImpl.java | 220 ++++++++-------- .../runtime/tasks/mailbox/MailboxReceiver.java | 12 +- .../runtime/tasks/mailbox/MailboxSender.java | 20 +- .../tasks/mailbox/MailboxStateException.java | 20 +- .../mailbox/execution/DefaultActionContext.java | 43 +--- .../mailbox/execution/MailboxDefaultAction.java | 19 +- .../tasks/mailbox/execution/MailboxExecutor.java | 71 ++++++ .../mailbox/execution/MailboxExecutorService.java | 23 +- .../execution/MailboxExecutorServiceImpl.java | 137 ++++++++++ .../tasks/mailbox/execution/MailboxProcessor.java | 279 +++++++++++++++++++++ .../execution/SuspendedMailboxDefaultAction.java | 12 +- .../tasks/StreamTaskSelectiveReadingTest.java | 3 +- .../runtime/tasks/StreamTaskTerminationTest.java | 3 +- .../streaming/runtime/tasks/StreamTaskTest.java | 13 +- .../runtime/tasks/SynchronousCheckpointITCase.java | 5 +- .../runtime/tasks/SynchronousCheckpointTest.java | 3 +- .../tasks/TaskCheckpointingBehaviourTest.java | 3 +- .../runtime/tasks/mailbox/MailboxImplTest.java | 182 ++++++++++---- .../execution/MailboxExecutorServiceImplTest.java | 178 +++++++++++++ .../mailbox/execution/MailboxProcessorTest.java | 266 ++++++++++++++++++++ .../mailbox/execution/TestMailboxExecutor.java | 49 ++-- .../flink/streaming/util/MockStreamTask.java | 3 +- .../jobmaster/JobMasterStopWithSavepointIT.java | 5 +- 29 files changed, 1410 insertions(+), 400 deletions(-) copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/sqlexec/SqlConversionException.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxStateException.java (62%) copy flink-core/src/main/java/org/apache/flink/util/CloseableIterable.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/DefaultActionContext.java (51%) copy flink-runtime/src/main/java/org/apache/flink/runtime/state/OwnedTaskLocalStateStore.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxDefaultAction.java (59%) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutor.java copy flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/IntType.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorService.java (69%) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorServiceImpl.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxProcessor.java copy flink-runtime/src/main/java/org/apache/flink/runtime/state/Keyed.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/SuspendedMailboxDefaultAction.java (75%) create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorServiceImplTest.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxProcessorTest.java copy flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/NonRollingBucketer.java => flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/TestMailboxExecutor.java (52%)