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 2022/01/21 15:15:06 UTC

[flink] branch master updated (9aa879f -> 2e98b3f)

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 9aa879f  [FLINK-25683][table] Pass MAX_WATERMARK in InputConversionOperator
     add de5a699  [hotfix][pulsar] Use correct super types for reader and fetcher manager.
     add 2e98b3f  [hotfix][source] Use only one watermark class in SourceOperatorEventTimeTest.

No new revisions were added by this update.

Summary of changes:
 .../pulsar/source/reader/fetcher/PulsarFetcherManagerBase.java |  4 ++--
 .../pulsar/source/reader/source/PulsarSourceReaderBase.java    |  4 ++--
 .../api/operators/source/SourceOperatorEventTimeTest.java      | 10 +++-------
 3 files changed, 7 insertions(+), 11 deletions(-)