[jira] [Created] (FLINK-10611) Documentation should describe how to choose between Rolling & Streaming file sink

2018-10-19 Thread Christophe Jolif (JIRA)
Christophe Jolif created FLINK-10611: Summary: Documentation should describe how to choose between Rolling & Streaming file sink Key: FLINK-10611 URL: https://issues.apache.org/jira/browse/FLINK-1

Re: Elasticsearch Sink

2018-05-18 Thread Christophe Jolif
ussion there. > Ideally we have this in early in the 1.6 release cycle, so that the > Elasticsearch e2e tests (will be merging a PR for that soon) can catching > anything unexpected. > > Cheers, > Gordon > > > On 16 May 2018 at 4:26:36 PM, Christophe Jolif (cjo...@gmail.com

Re: Elasticsearch Sink

2018-05-16 Thread Christophe Jolif
] https://github.com/elastic/elasticsearch/blob/v5. > 2.2/core/src/main/java/org/elasticsearch/action/bulk/BulkRequest.java#L110 > [2] https://github.com/elastic/elasticsearch/blob/v6. > 2.4/server/src/main/java/org/elasticsearch/action/bulk/ > BulkRequest.java#L128 > > On 16 May 2018

Re: Elasticsearch Sink

2018-05-15 Thread Christophe Jolif
with a proper fix. > > Some other remarks / questions I have: > - Maybe we can consider removing support for ES 1.x and 2.x starting from > 1.6. Those are very old ES versions (considering that ES 6.x has already > been out for a while). Do you think this would simply how our base mod

Re: Elasticsearch Sink

2018-05-13 Thread Christophe Jolif
.x (covering both 5.2 and 5.3+)? If so, > once we remove ES 1.x and 2.x, it might actually be possible to completely > replace the current `elasticsearch-base` module. > > Cheers, > Gordon > > > On Sun, May 13, 2018 at 12:36 AM, Flavio Pompermaier > > wrote: > > &

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

Re: [DISCUSS] Releasing Flink 1.5.0

2018-04-12 Thread Christophe Jolif
Hi all, A small patch: https://github.com/apache/flink/pull/5789 (JIRA: https://issues.apache.org/jira/browse/FLINK-9103) was issued to help with SSL certificates in Kubernetes deployment where you don't control your IPs. As this is very small and helpful (at least to me and Edward who issued the

[jira] [Created] (FLINK-9071) Dataflow programming model documentation example is referencing deprecated RollingSink

2018-03-25 Thread Christophe Jolif (JIRA)
Christophe Jolif created FLINK-9071: --- Summary: Dataflow programming model documentation example is referencing deprecated RollingSink Key: FLINK-9071 URL: https://issues.apache.org/jira/browse/FLINK-9071

Re: FLIP-6 / Kubernetes

2018-03-21 Thread Christophe Jolif
Hi Stephan, > This feature did not make it for 1.5, but should come very soon after. Are you talking about a 1.5.1 here? What is the envisioned timeline? Thanks! On Tue, Mar 20, 2018 at 9:30 PM, Stephan Ewen wrote: > @Eron That is definitely the way we want to suggest as the way to use k8s >

Re: [DISCUSS] Releasing Flink 1.5.0

2018-02-05 Thread Christophe Jolif
Hi guys, Sorry for jumping in, but I think [FLINK-8101] Elasticsearch 6.X support [FLINK-7386] Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client have long been awaited and there was one PR from me and from someone else showing the interest ;) So if you could cons

[jira] [Created] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-01-12 Thread Christophe Jolif (JIRA)
Christophe Jolif created FLINK-8426: --- Summary: Error in Generating Timestamp/Watermakr doc Key: FLINK-8426 URL: https://issues.apache.org/jira/browse/FLINK-8426 Project: Flink Issue Type