[FLINK-27890] SideOutputExample.java fails

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.15.1, 1.16.0
• Component/s: Examples
• Labels: pull-request-available

Environment

1. flink version 1.15
2. jdk 1.8
3. scala 2.12

• Assignee: CodeRap
• Reporter: XiaoWen Wei
• Created: 03/Jun/22 07:16
• Updated: 17/Jun/22 13:08
• Resolved: 13/Jun/22 08:25

Description

The bug appears on line 87 of flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/sideoutput/SideOutputExample.java：

text.assignTimestampsAndWatermarks(IngestionTimeWatermarkStrategy.create()); 

This line forgets to set the return value, so the timestamp is not assigned to the element in text. As a result, running this code throws an error.

Issue Links

• is caused by: FLINK-19317 Make EventTime the default StreamTimeCharacteristic
• links to: GitHub Pull Request #19924