Re: Flink job repeated restart failure

setting to a valid value as suggested. Kind regards, Vinaya -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Flink job repeated restart failure

ugh in our case, we didn't notice any disk failure. Is there any other reason(s) for the above mentioned IOException? While we are planning to upgrade to the latest Flink version, are there any other workaround(s) instead of deploying the job again with a different file name? Kind regards, Vinaya

Apache Flink Deployment in Multiple AZ

Hi, Is Apache Flink (Job Managers, Task Managers) setup in multiple availability zones a recommended deployment model? Kind regards, Vinaya

Apache Flink Job Manager High CPU with Couchbase

possible reasons for creation of numerous cb-* threads on Flink Job Manager. If you have any other suggestions or commands to better troubleshoot this issue, those are welcome too. Thank you. Kind regards, Vinaya

Flink_Kafka

found for some partitions in topic KafkaTweet. Fetched the following start offsets [FetchPartition {partition=0, offset=3061}] I'm using Flink: 0.10.1 and Kafka:8.2.2 and flink-connector-kafka 10.1. *Any help would be much appreciated.* *Thank you,* *Vinaya*

Kafka+Flink

in kafka2: host.name: flink-data2 IP in kafka3: host.name: flink-data3 IP My question is, In order to connect to kafka how should my conf/producer.yaml look like? kafka.brokers: ?? zookeeper.servers: ?? kafka.port: 9092 zookeeper.port: 2181 kafka.topic: "" kafka.partitions: 1 Thanks, Vinaya

Re: Comparison of storm and flink

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

Comparison of storm and flink

compared to Storm? Thanks! Vinaya

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

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

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

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