XiaoWen Wei created FLINK-27890: ----------------------------------- Summary: bug of SideOutputExample.java Key: FLINK-27890 URL: https://issues.apache.org/jira/browse/FLINK-27890 Project: Flink Issue Type: Bug Components: Examples Affects Versions: 1.15.0 Environment: # flink version 1.15 # jdk 1.8 # scala 2.12 Reporter: XiaoWen Wei Fix For: 1.15.0
The bug appears on line 87 of flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/sideoutput/SideOutputExample.javaļ¼ {code:java} text.assignTimestampsAndWatermarks(IngestionTimeWatermarkStrategy.create()); {code} 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. -- This message was sent by Atlassian Jira (v8.20.7#820007)