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
...@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
@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
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,
&
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
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
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
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
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
