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

docs and examples use deprecated forms of keyBy

    XMLWordPrintableJSON

Details

    Description

      The DataStream example at https://ci.apache.org/projects/flink/flink-docs-stable/dev/datastream_api.html#example-program uses

      keyBy(0)

      which has been deprecated. There are many other cases of this throughout the docs:

      dev/connectors/cassandra.md
      dev/parallel.md
      dev/stream/operators/index.md
      dev/stream/operators/process_function.md
      dev/stream/state/queryable_state.md
      dev/stream/state/state.md
      dev/types_serialization.md
      learn-flink/etl.md
      ops/scala_shell.md

      and also in a number of examples:

      AsyncIOExample.java
      SideOutputExample.java
      TwitterExample.java
      GroupedProcessingTimeWindowExample.java
      SessionWindowing.java
      TopSpeedWindowing.java
      WindowWordCount.java
      WordCount.java
      TwitterExample.scala
      GroupedProcessingTimeWindowExample.scala
      SessionWindowing.scala
      WindowWordCount.scala
      WordCount.scala

      There are also some uses of keyBy("string"), which has also been deprecated:

      dev/connectors/cassandra.md
      dev/stream/operators/index.md
      dev/types_serialization.md
      learn-flink/etl.md

      SocketWindowWordCount.java
      SocketWindowWordCount.scala
      TopSpeedWindowing.scala

      Attachments

        Issue Links

          Activity

            People

              wuleiflink wulei0302
              alpinegizmo David Anderson
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: