Martijn Visser created FLINK-41161:
--------------------------------------
Summary: Migrate TimestampITCase to Source V2
Key: FLINK-41161
URL: https://issues.apache.org/jira/browse/FLINK-41161
Project: Flink
Issue Type: Sub-task
Components: Test Infrastructure
Reporter: Martijn Visser
Three named and five anonymous sources with explicit timestamps and watermarks,
including two Long.MAX_VALUE watermarks. The exact watermark-count assertions
have to account for the MAX_WATERMARK a Source V2 operator emits at end of
input. Keep
AscendingRecordTimestampsWatermarkStrategy, which IntervalJoinITCase uses.
We should revive https://github.com/apache/flink/pull/26865 on this one
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
