[flink] branch master updated (aa21c11 -> a5611de)

[ar...@apache.org]

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