[FLINK-22598] Examples use deprecated method of writeAsText

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.11.3, 1.12.0, 1.12.1, 1.12.2, 1.13.0
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: Examples
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Unassigned
• Reporter: Linying Assad
• Created: 08/May/21 03:04
• Updated: 08/Oct/21 11:22

Description

 

The DataStream examples at https://github.com/apache/flink/tree/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples uses

DataStream#writeAsText() which has been deprecated.

 

The associated deprecated calls to example code are distributed as follows:

• org/apache/flink/streaming/examples/wordcount/WordCount.java
• org/apache/flink/streaming/examples/windowing/WindowWordCount.java
• org/apache/flink/streaming/examples/windowing/SessionWindowing.java
• org/apache/flink/streaming/examples/twitter/TwitterExample.java
• org/apache/flink/streaming/examples/sideoutput/SideOutputExample.java
• org/apache/flink/streaming/examples/iteration/IterateExample.java

According to the code description, this API call should be replaced by the addSink API.

 

I feel that the project example code should not use deprecated APIs, which could be misleading to the reference, and should keep the API usage examples up to date. 

 

Issue Links

• links to: GitHub Pull Request #15860