Fabian Paul created FLINK-24032: ----------------------------------- Summary: StreamSink does not receive periodic watermarks Key: FLINK-24032 URL: https://issues.apache.org/jira/browse/FLINK-24032 Project: Flink Issue Type: Bug Components: Runtime / Task Affects Versions: 1.14.0 Reporter: Fabian Paul
In the following scenario, the sink will never receive watermarks {code:java} env.readFile(...) .assignTimestampsAndWatermarks(format, file) .rebalance() .addSink(...); {code} I also noticed that when changing the code to the following the watermarks flow to the sink {code:java} env.readFile(...) .assignTimestampsAndWatermarks(format, file) .rebalance() .process(new ProcessFunction() {...}) .addSink(...); {code} An example test case is accessible here [https://github.com/fapaul/flink/blob/9b749ac80cd128a7f288da45db313bafa39d8008/flink-tests/src/test/java/org/apache/flink/test/streaming/api/FileReadingWatermarkITCase.java#L68] -- This message was sent by Atlassian Jira (v8.3.4#803005)