Shimin Yang created FLINK-10000: ----------------------------------- Summary: There's a mistake in the comments of CoGroupedStreams.java Key: FLINK-10000 URL: https://issues.apache.org/jira/browse/FLINK-10000 Project: Flink Issue Type: Improvement Components: DataStream API Reporter: Shimin Yang Assignee: Shimin Yang
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()); * } </pre> the params of method equalTo should be MySecondKeySelector instead of MyFirstKeySelector. -- This message was sent by Atlassian JIRA (v7.6.3#76005)