@Fabian: I will run the code with the Git repo source and let you know the results.
@Stephan: Sorry I missed the email from you somehow. I understand from the JIRA link that you already have the answer for this. Yet I tried using two separate config map objects in my code and that resolved the issue. Both the sinks wrote into Elasticsearch as expected.
Thank you for taking this up. I will report back on the test results soon.
From: Fabian Hueske [mailto:fhueske@xxxxxxxxx]
a potential fix for the issue has been merged: https://issues.apache.org/jira/browse/FLINK-8489
It would be great if you could check if that fixes the problem and report back.
2018-01-23 20:04 GMT+01:00 Stephan Ewen <sewen@xxxxxxxxxx>: