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

Reply via email to