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 <vinay...@gmail.com> 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.
>
