This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from aa21c11 [FLINK-23587][k8s] Set the annotations on JobManager
deployment when using native kubernetes
add 5663149 [FLINK-23621][datastream] Adding InterruptedException to Sink
interfaces to facilitate async communication patterns.
add 5735fff [FLINK-23621][core] Move MailboxExecutor to flink-core and
org.apache.flink.streaming.api.operators
add 4bf565b [FLINK-23621][operators] Add MailboxExecutor handling to
AbstractSinkWriterOperatorFactory such that extending factories only need to
implement YieldingOperatorFactory to access it.
add a5611de [FLINK-23621][datastream] Adding mailbox, userClassLoader,
and numberOfParallelSubtasks to Sink#InitContext.
No new revisions were added by this update.
Summary of changes:
.../api/common/operators}/MailboxExecutor.java | 29 +++++++-----
.../apache/flink/api/connector/sink/Committer.java | 2 +-
.../flink/api/connector/sink/GlobalCommitter.java | 5 +-
.../org/apache/flink/api/connector/sink/Sink.java | 23 +++++++++
.../flink/api/connector/sink/SinkWriter.java | 6 +--
.../util/function}/FutureTaskWithException.java | 5 +-
.../flink/runtime/execution/Environment.java | 2 +-
.../runtime/taskmanager/RuntimeEnvironment.java | 2 +-
.../flink/runtime/mailbox/SyncMailboxExecutor.java | 1 +
.../operators/testutils/MockEnvironment.java | 2 +-
.../changelog/ChangelogKeyedStateBackend.java | 2 +-
.../source/ContinuousFileReaderOperator.java | 2 +-
.../ContinuousFileReaderOperatorFactory.java | 9 +---
.../operators/AbstractStreamOperatorFactory.java | 19 ++++++++
.../api/operators/StreamOperatorFactoryUtil.java | 2 +-
.../api/operators/YieldingOperatorFactory.java | 2 +-
.../api/operators/async/AsyncWaitOperator.java | 2 +-
.../operators/async/AsyncWaitOperatorFactory.java | 9 +---
.../io/checkpointing/CheckpointedInputGate.java | 2 +-
.../io/checkpointing/InputProcessorUtil.java | 2 +-
.../operators/sink/AbstractSinkWriterOperator.java | 54 ++++++++++++++++++----
.../sink/AbstractSinkWriterOperatorFactory.java | 4 +-
.../operators/sink/StatefulSinkWriterOperator.java | 4 +-
.../sink/StatefulSinkWriterOperatorFactory.java | 1 +
.../sink/StatelessSinkWriterOperator.java | 4 +-
.../sink/StatelessSinkWriterOperatorFactory.java | 2 +-
.../tasks/ProcessingTimeServiceFactory.java | 2 +-
.../runtime/tasks/StreamOperatorWrapper.java | 2 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 2 +-
.../tasks/mailbox/MailboxExecutorFactory.java | 2 +-
.../runtime/tasks/mailbox/MailboxExecutorImpl.java | 2 +-
.../runtime/tasks/mailbox/MailboxProcessor.java | 2 +-
.../runtime/tasks/mailbox/TaskMailbox.java | 2 +-
.../api/graph/StreamingJobGraphGeneratorTest.java | 2 +-
.../runtime/operators/MailboxOperatorTest.java | 2 +-
.../operators/StreamTaskOperatorTimerTest.java | 2 +-
.../operators/sink/SinkWriterOperatorTestBase.java | 51 ++++++++++++++++++++
.../streaming/runtime/operators/sink/TestSink.java | 3 ++
.../runtime/tasks/StreamOperatorWrapperTest.java | 2 +-
.../tasks/StreamTaskMailboxTestHarness.java | 2 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 2 +-
.../runtime/tasks/StreamTaskTestHarness.java | 2 +-
.../tasks/mailbox/MailboxExecutorImplTest.java | 2 +-
.../tasks/mailbox/TaskMailboxProcessorTest.java | 4 +-
.../util/TestCheckpointedInputGateBuilder.java | 2 +-
45 files changed, 210 insertions(+), 77 deletions(-)
rename {flink-runtime/src/main/java/org/apache/flink/runtime/mailbox =>
flink-core/src/main/java/org/apache/flink/api/common/operators}/MailboxExecutor.java
(93%)
rename {flink-runtime/src/main/java/org/apache/flink/runtime/concurrent =>
flink-core/src/main/java/org/apache/flink/util/function}/FutureTaskWithException.java
(92%)
