[
https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175467#comment-17175467
]
Jark Wu commented on FLINK-18797:
---------------------------------
Assigned to you [~wuleiflink]
> docs and examples use deprecated forms of keyBy
> -----------------------------------------------
>
> Key: FLINK-18797
> URL: https://issues.apache.org/jira/browse/FLINK-18797
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Examples
> Affects Versions: 1.11.0, 1.11.1
> Reporter: David Anderson
> Assignee: wulei0302
> Priority: Major
>
> 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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
