flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinaya M S <vinay...@gmail.com>
Subject groupBy(int) is undefined for the type SingleOutputStreamOperator while running streaming example provided on webpage
Date Wed, 20 Jan 2016 14:37:37 GMT

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())



Thank you.

View raw message