groupBy(int) is undefined for the type SingleOutputStreamOperator while running streaming example provided on webpage

[Vinaya M S]

Hi,

I'm new to Flink. Can anyone help me with the error below.

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 

The method groupBy(int) is undefined for the type SingleOutputStreamOperator<Tuple2<String,Integer>,capture#1-of ?>

The code snippet is:

DataStream<Tuple2<String, Integer>> dataStream = env

                .socketTextStream("localhost", 9999)

                .flatMap(new Splitter())

                .groupBy(0)

                .sum(1);

Thank you.

[rmetzger0]

Hi.

which Flink version are you using? 

Starting from Flink 0.10., "groupBy" has been renamed to "keyBy".

Where did you find the "groupBy" example?

On Wed, Jan 20, 2016 at 3:37 PM, Vinaya M S <[hidden email]> wrote:

Hi,

I'm new to Flink. Can anyone help me with the error below.

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 

The method groupBy(int) is undefined for the type SingleOutputStreamOperator<Tuple2<String,Integer>,capture#1-of ?>

The code snippet is:

DataStream<Tuple2<String, Integer>> dataStream = env

                .socketTextStream("localhost", 9999)

                .flatMap(new Splitter())

                .groupBy(0)

                .sum(1);

Thank you.

[Vinaya M S]

Version FLink 0.10.

Example is mentioned in https://ci.apache.org/projects/flink/flink-docs-release-0.8/streaming_guide.html

Please let me know where I can find these kind of updates.

Thank you.

On Wed, Jan 20, 2016 at 9:41 AM, Robert Metzger <[hidden email]> wrote:

Hi.

which Flink version are you using? 

Starting from Flink 0.10., "groupBy" has been renamed to "keyBy".

Where did you find the "groupBy" example?

On Wed, Jan 20, 2016 at 3:37 PM, Vinaya M S <[hidden email]> wrote:

Hi,

I'm new to Flink. Can anyone help me with the error below.

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 

The method groupBy(int) is undefined for the type SingleOutputStreamOperator<Tuple2<String,Integer>,capture#1-of ?>

The code snippet is:

DataStream<Tuple2<String, Integer>> dataStream = env

                .socketTextStream("localhost", 9999)

                .flatMap(new Splitter())

                .groupBy(0)

                .sum(1);

Thank you.

[rmetzger0]

Hi,

as you can see from the URL, its the documentation for Flink 0.8. The current documentation is here: https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/streaming_guide.html

In the 0.10. release announcement (http://flink.apache.org/news/2015/11/16/release-0.10.0.html ) the change has been mentioned.

On Wed, Jan 20, 2016 at 3:47 PM, Vinaya M S <[hidden email]> wrote:

Version FLink 0.10.

Example is mentioned in https://ci.apache.org/projects/flink/flink-docs-release-0.8/streaming_guide.html

Please let me know where I can find these kind of updates.

Thank you.

On Wed, Jan 20, 2016 at 9:41 AM, Robert Metzger <[hidden email]> wrote:

Hi.

which Flink version are you using? 

Starting from Flink 0.10., "groupBy" has been renamed to "keyBy".

Where did you find the "groupBy" example?

On Wed, Jan 20, 2016 at 3:37 PM, Vinaya M S <[hidden email]> wrote:

Hi,

I'm new to Flink. Can anyone help me with the error below.

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 

The method groupBy(int) is undefined for the type SingleOutputStreamOperator<Tuple2<String,Integer>,capture#1-of ?>

The code snippet is:

DataStream<Tuple2<String, Integer>> dataStream = env

                .socketTextStream("localhost", 9999)

                .flatMap(new Splitter())

                .groupBy(0)

                .sum(1);

Thank you.