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/18 14:14:19 UTC

[flink] branch master updated (91fcd83 -> bc0466b)

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 91fcd83  [FLINK-15961][table-planner][table-planner-blink] Add physical Python Correlate rules and RelNodes
     add d3cb7ed  [FLINK-16056][runtime][tests] do fail ContinuousFileProcessingITCase on failure
     add 468f90f  [FLINK-16056][runtime][tests] create ContinuousFileReaderOperator using factory only Also drop test constructor and make the class package-private.
     add bc0466b  [FLINK-16056][docs] update StreamExecutionEnvironment javadoc

No new revisions were added by this update.

Summary of changes:
 .../hdfstests/ContinuousFileProcessingITCase.java  | 42 +++++++++-------------
 .../ContinuousFileProcessingMigrationTest.java     | 22 ++++++------
 .../hdfstests/ContinuousFileProcessingTest.java    | 35 ++++++++----------
 .../environment/StreamExecutionEnvironment.java    | 15 ++++----
 .../source/ContinuousFileReaderOperator.java       | 11 ++----
 .../ContinuousFileReaderOperatorFactory.java       |  6 ++++
 .../ContinuousFileProcessingRescalingTest.java     | 16 +++++----
 7 files changed, 65 insertions(+), 82 deletions(-)