Mason Chen

[FLINK-28185][Connector/Kafka] Make TimestampOffsetsInitializer apply offset reset str…

2

…ategy and handle timestamps that do not map to an offset ## What is the purpose of the change This change improves the TimestampOffsetsInitializer to be initialized with a configured...

[FLINK-34127] Upgrade to flink-connector-parent 1.1.0 to exclude runn…

1

…ing nested unit tests The root cause of the duplicate nested test execution is noted in this github issue: https://github.com/junit-team/junit5/issues/3782. TLDR, the outer test runs once (running all its nested...