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

Posted to commits@flink.apache.org by ma...@apache.org on 2022/11/25 07:48:36 UTC

[flink] branch master updated (5086a33f410 -> e44ecf05365)

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 5086a33f410 [FLINK-30133][hadoop] Changes log level and make log message more descriptive.
     add e44ecf05365 [FLINK-28185][Connector/Kafka] Handle missing timestamps when there are empty partitions for the TimestampOffsetsInitializer. This closes #20370

No new revisions were added by this update.

Summary of changes:
 .../source/enumerator/KafkaSourceEnumerator.java   |  4 ++++
 .../enumerator/initializer/OffsetsInitializer.java |  2 +-
 .../initializer/TimestampOffsetsInitializer.java   | 27 +++++++++++-----------
 .../initializer/OffsetsInitializerTest.java        | 18 ++++++++++++++-
 4 files changed, 36 insertions(+), 15 deletions(-)