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,capture#1-of ?>
The code snippet is:
DataStream> dataStream = env
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 wrote:
>
>> Hi,
>>
>> I'm new to Flink. Can anyon
Hi Flink user group,
I am working on a project for the Insight Data Engineering Program in New
York to compare streaming tools. The program is designed for software
engineers and those straight from the university to transition to a data
engineering role. After completing the project, we present
y. But I wanted to be careful and would be
willing to work further on those lines.
I have enrolled for the meet up happening at NYC as I consider it to be
great place to gain knowledge on flink. Looking forward for your talk as
well as to meet you and discuss the questions I have.
Thank you,
Vi
Hi,
I have a 3 node kafka cluster. In server.properties file of each of them
I'm setting
advertisedhost.name: to its IP.
I have 4 node flink cluster. In each of kaka's node I'm setting
host.name: to one of link's worker node.
like,
in kafka1:
host.name: flink-data1IP
in kafka2:
host.name: fl
Hi,
I'm new to Flink. I was working with Flink and Kafka before. It was working
fine.
But now Flink is not able to consume data from Kafka even with newly
created topic.
This is the log:
15:12:59,684 INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer - No prior
offsets found f
