Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22598

Examples use deprecated method of writeAsText

    XMLWordPrintableJSON

Details

    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. 

       

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              Al-assad Linying Assad
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: