Re: Multiple Elasticsearch sinks not working in Flink

2018-02-05 Thread Fabian Hueske
t; > > > *From:* Teena Kappen // BPRISE > *Sent:* 01 February 2018 19:12 > *To:* Fabian Hueske ; Stephan Ewen > *Cc:* Timo Walther ; user@flink.apache.org > *Subject:* RE: Multiple Elasticsearch sinks not working in Flink > > > > @Fabian: I will run the code with the

RE: Multiple Elasticsearch sinks not working in Flink

2018-02-03 Thread Teena Kappen // BPRISE
...@apache.org>> Cc: Teena Kappen // BPRISE mailto:teena.kap...@bprise.com>>; Timo Walther mailto:twal...@apache.org>>; user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Multiple Elasticsearch sinks not working in Flink Hi Teena, a potential fix for the issue

RE: Multiple Elasticsearch sinks not working in Flink

2018-02-01 Thread Teena Kappen // BPRISE
@flink.apache.org Subject: Re: Multiple Elasticsearch sinks not working in Flink Hi Teena, a potential fix for the issue has been merged: https://issues.apache.org/jira/browse/FLINK-8489<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fissues.apache.org%2Fjira%2Fbrowse%2FFLINK-8

Re: Multiple Elasticsearch sinks not working in Flink

2018-01-31 Thread Fabian Hueske
Fabian Hueske [mailto:fhue...@gmail.com] >> *Sent:* 23 January 2018 15:20 >> *To:* Teena Kappen // BPRISE >> *Cc:* Timo Walther ; user@flink.apache.org >> >> *Subject:* Re: Multiple Elasticsearch sinks not working in Flink >> >> >> >> Hi Teena, &

Re: Multiple Elasticsearch sinks not working in Flink

2018-01-23 Thread Stephan Ewen
n Hueske [mailto:fhue...@gmail.com] > *Sent:* 23 January 2018 15:20 > *To:* Teena Kappen // BPRISE > *Cc:* Timo Walther ; user@flink.apache.org > > *Subject:* Re: Multiple Elasticsearch sinks not working in Flink > > > > Hi Teena, > > I created FLINK-8489

RE: Multiple Elasticsearch sinks not working in Flink

2018-01-23 Thread Teena Kappen // BPRISE
Thanks Fabian. I will go through it and add info if required. From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: 23 January 2018 15:20 To: Teena Kappen // BPRISE Cc: Timo Walther ; user@flink.apache.org Subject: Re: Multiple Elasticsearch sinks not working in Flink Hi Teena, I created FLINK

Re: Multiple Elasticsearch sinks not working in Flink

2018-01-23 Thread Fabian Hueske
second sink is a Cassandra Sink. The data gets read > from KafkaTopic2 and it gets written to Cassandra as expected. > > > > Regards, > > Teena > > > > *From:* Timo Walther [mailto:twal...@apache.org] > *Sent:* 18 January 2018 18:41 > *To:* user@flink.apache

RE: Multiple Elasticsearch sinks not working in Flink

2018-01-18 Thread Teena Kappen // BPRISE
Elasticsearch sinks not working in Flink Hi Teena, what happens if you replace the second sink with a non-ElasticSearchSink? Is there the same result? Is the data read from the KafkaTopic2? We should determine which system is the bottleneck. Regards, Timo Am 1/18/18 um 9:53 AM schrieb Teena Kappen

Re: Multiple Elasticsearch sinks not working in Flink

2018-01-18 Thread Timo Walther
Hi Teena, what happens if you replace the second sink with a non-ElasticSearchSink? Is there the same result? Is the data read from the KafkaTopic2? We should determine which system is the bottleneck. Regards, Timo Am 1/18/18 um 9:53 AM schrieb Teena Kappen // BPRISE: Hi, I am running f

Multiple Elasticsearch sinks not working in Flink

2018-01-18 Thread Teena Kappen // BPRISE
Hi, I am running flink 1.4 in single node. My job has two Kafka consumers reading from separate topics. After fetching the data, the job writes it to two separate Elasticsearch sinks. So the process is like this KafkaTopic1 -> Kafkaconsumer1 -> create output record -> Elasticsearchsink1 KafkaTo