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