You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2020/02/10 11:30:14 UTC

[flink] branch master updated (6bf9cf2 -> 2e96ee7)

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 6bf9cf2  [FLINK-15741][docs-zh][TTL] Fix TTL docs after enabling RocksDB compaction filter by default
     add 3f5a8c7  [hotfix][runtime,test] refactor ContinuousFileProcessingRescalingTest to prepare for ContinuousFileReaderOperator migration to Mailbox Execution model
     add 2e96ee7  [FLINK-13955][runtime] use mailbox execution model in ContinuousFileReaderOperator.

No new revisions were added by this update.

Summary of changes:
 .../ContinuousFileProcessingMigrationTest.java     |   3 +-
 .../hdfstests/ContinuousFileProcessingTest.java    |  34 +-
 .../environment/StreamExecutionEnvironment.java    |   6 +-
 .../source/ContinuousFileReaderOperator.java       | 595 ++++++++++++---------
 .../ContinuousFileReaderOperatorFactory.java}      |  61 ++-
 .../runtime/tasks/mailbox/MailboxProcessor.java    |  10 +-
 .../ContinuousFileProcessingRescalingTest.java     | 353 ++++++------
 .../tasks/mailbox/SteppingMailboxProcessor.java    |  58 ++
 .../util/AbstractStreamOperatorTestHarness.java    |  12 +
 .../flink/streaming/util/MockStreamTask.java       |   9 +-
 .../streaming/util/MockStreamTaskBuilder.java      |  19 +-
 .../util/OneInputStreamOperatorTestHarness.java    |   1 +
 12 files changed, 654 insertions(+), 507 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/{operators/async/AsyncWaitOperatorFactory.java => functions/source/ContinuousFileReaderOperatorFactory.java} (59%)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/SteppingMailboxProcessor.java