Re: Elasticsearch Sink

2018-05-12 Thread Tzu-Li (Gordon) Tai
Hi Christophe, Thanks for bringing this up. Yes, the main issue with the existing PRs and preventing it from moving forward is how it currently breaks initial assumptions of APIs in the `elasticsearch-base` module. Working around that would require introducing a new base module specifically for 5

Re: [Discuss] FLIP-26 - SSL Mutual Authentication

2018-05-12 Thread Stephan Ewen
Thank you for bringing this proposal up. It looks very good and we seem to be thinking along very similar lines. Below are some comments and thoughts on the FLIP. *Internal vs. External Connectivity* That is a very helpful distinction, let's build on that. - I would suggest to treat eventuall

[jira] [Created] (FLINK-9348) scalastyle documentatiom for IntelliJ IDE setup

2018-05-12 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9348: -- Summary: scalastyle documentatiom for IntelliJ IDE setup Key: FLINK-9348 URL: https://issues.apache.org/jira/browse/FLINK-9348 Project: Flink Issue Type:

[jira] [Created] (FLINK-9347) BlobServerConnection throws misleading exception for empty files

2018-05-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9347: --- Summary: BlobServerConnection throws misleading exception for empty files Key: FLINK-9347 URL: https://issues.apache.org/jira/browse/FLINK-9347 Project: Flink

Re: Elasticsearch Sink

2018-05-12 Thread Flavio Pompermaier
+1. Torally agree On Sat, 12 May 2018, 18:14 Christophe Jolif, wrote: > Hi all, > > There is quite some time Flink Elasticsearch sink is broken for > Elastisearch 5.x (nearly a year): > > https://issues.apache.org/jira/browse/FLINK-7386 > > And there is no support for Elasticsearch 6.x: > > htt

Elasticsearch Sink

2018-05-12 Thread Christophe Jolif
Hi all, There is quite some time Flink Elasticsearch sink is broken for Elastisearch 5.x (nearly a year): https://issues.apache.org/jira/browse/FLINK-7386 And there is no support for Elasticsearch 6.x: https://issues.apache.org/jira/browse/FLINK-8101 However several PRs were issued: https://

[jira] [Created] (FLINK-9346) Update documents for supporting intersect/except in streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9346: - Summary: Update documents for supporting intersect/except in streaming Key: FLINK-9346 URL: https://issues.apache.org/jira/browse/FLINK-9346 Project: Flink Issue

[jira] [Created] (FLINK-9345) Support EXCEPT and EXCEPT ALL for streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9345: - Summary: Support EXCEPT and EXCEPT ALL for streaming Key: FLINK-9345 URL: https://issues.apache.org/jira/browse/FLINK-9345 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming

2018-05-12 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9344: - Summary: Support INTERSECT and INTERSECT ALL for streaming Key: FLINK-9344 URL: https://issues.apache.org/jira/browse/FLINK-9344 Project: Flink Issue Type: Improve