[flink] branch master updated (a40b31b -> ccc7eb4)

[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 a40b31b  [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1
     add b291bd5  [hotfix] [runtime] Replacing mockito in AsyncWaitOperatorTest
     add 8805406  [FLINK-13248][runtime] Implement per operator priorities for mailbox actions and yieldToDownstream concept
     add 0d8670b  [FLINK-13248] [runtime] Adding and using YieldableOperatorFactory to pass MailboxExecutor view to operator
     add ccc7eb4  [FLINK-13248] [datastream/streaming] Enabling custom factories for one input stream operators to be passed in DataStream

No new revisions were added by this update.

Summary of changes:
 .../flink/state/api/output/BoundedStreamTask.java  |   7 +-
 .../flink/streaming/api/datastream/DataStream.java |  41 +++-
 ...put.java => OneInputStreamOperatorFactory.java} |  15 +-
 .../api/operators/StreamOperatorFactoryUtil.java   |  51 +++++
 ...dOneInput.java => YieldingOperatorFactory.java} |  14 +-
 .../streaming/runtime/tasks/OperatorChain.java     |  33 ++-
 .../flink/streaming/runtime/tasks/StreamTask.java  |   6 +-
 .../streaming/runtime/tasks/mailbox/Mailbox.java   |  55 +----
 .../runtime/tasks/mailbox/MailboxReceiver.java     |   5 -
 .../runtime/tasks/mailbox/MailboxSender.java       |   9 +
 .../runtime/tasks/mailbox/TaskMailbox.java         | 137 ++++++++++++
 .../{MailboxImpl.java => TaskMailboxImpl.java}     | 108 +++++++--
 .../tasks/mailbox/execution/MailboxExecutor.java   |  18 ++
 .../mailbox/execution/MailboxExecutorFactory.java  |  19 +-
 ...orServiceImpl.java => MailboxExecutorImpl.java} |  35 +--
 .../mailbox/execution/MailboxExecutorService.java  |  29 ---
 .../tasks/mailbox/execution/MailboxProcessor.java  |  57 +++--
 .../api/operators/async/AsyncWaitOperatorTest.java | 249 +++++++--------------
 ...ilboxImplTest.java => TaskMailboxImplTest.java} | 159 +++++++++----
 ...eImplTest.java => MailboxExecutorImplTest.java} |  69 +++---
 ...ssorTest.java => TaskMailboxProcessorTest.java} |  19 +-
 .../util/AbstractStreamOperatorTestHarness.java    |  97 ++++++--
 .../flink/streaming/util/MockStreamTask.java       |  22 +-
 .../util/OneInputStreamOperatorTestHarness.java    |  59 ++++-
 .../table/runtime/harness/HarnessTestBase.scala    |   8 +-
 25 files changed, 807 insertions(+), 514 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/{BoundedOneInput.java => OneInputStreamOperatorFactory.java} (74%)
 mode change 100755 => 100644
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactoryUtil.java
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/{BoundedOneInput.java => YieldingOperatorFactory.java} (68%)
 mode change 100755 => 100644
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailbox.java
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/{MailboxImpl.java => TaskMailboxImpl.java} (65%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ResultPartitionAvailabilityChecker.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorFactory.java (60%)
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/{MailboxExecutorServiceImpl.java => MailboxExecutorImpl.java} (76%)
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/MailboxExecutorService.java
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/{MailboxImplTest.java => TaskMailboxImplTest.java} (52%)
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/{MailboxExecutorServiceImplTest.java => MailboxExecutorImplTest.java} (63%)
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/execution/{MailboxProcessorTest.java => TaskMailboxProcessorTest.java} (91%)