[FLINK-10000] There's a mistake in the comments of CoGroupedStreams.java

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Fix
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Shimin Yang
• Reporter: Shimin Yang
• Created: 31/Jul/18 07:57
• Updated: 19/Sep/18 09:30
• Resolved: 19/Sep/18 09:30

Description

The example of CoGroupedStream

    DataStream<T> result = one.coGroup(two)
      .where(new MyFirstKeySelector())
      .equalTo(new MyFirstKeySelector())
      .window(TumblingEventTimeWindows.of(Time.of(5, TimeUnit.SECONDS)))
      .apply(new MyCoGroupFunction());
 

the params of method equalTo should be MySecondKeySelector instead of MyFirstKeySelector.

Issue Links

• links to: GitHub Pull Request #6463