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
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
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
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://
+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
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
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:
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
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