[jira] [Created] (FLINK-9401) Data lost when rescaling the job from incremental checkpoint

2018-05-18 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9401: - Summary: Data lost when rescaling the job from incremental checkpoint Key: FLINK-9401 URL: https://issues.apache.org/jira/browse/FLINK-9401 Project: Flink Issue T

Re: Elasticsearch Sink

2018-05-18 Thread Christophe Jolif
Hi Gordon, A first step: https://github.com/apache/flink/pull/6043 -- Christophe On Wed, May 16, 2018 at 12:16 PM, Tzu-Li (Gordon) Tai wrote: > Good to know! Thanks a lot for pushing this Christophe. > > Please ping me when the new PR is opened, and we can continue the > discussion there. > Id

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Ted Yu
bq. We can merge the fix to the master and see if the problem goes away. +1 On Fri, May 18, 2018 at 9:53 AM, Fabian Hueske wrote: > FLINK-9091 is hard to reproduce and only affects the build but no > functionality of Flink or its correctness. > IMO, we should not block the release it. > > Since

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Fabian Hueske
FLINK-9091 is hard to reproduce and only affects the build but no functionality of Flink or its correctness. IMO, we should not block the release it. Since it's hard to reproduce, we cannot be sure that Timo's fix actually solves the problem. We can merge the fix to the master and see if the probl

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Timo Walther
Hi Ted, I'm not sure if my branch fixes the problem entirely. It just minimizes the problem space and it would take some time to verify if the issues is solved because this error only occurs occasionally. I wouldn't reject the RC because of this. People could just disable the enforcer plugin

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Ted Yu
When I ran tests, I hit FLINK-9091 . It seems Timo already has a fix. It would be nice to include the fix since flink-json module is new in 1.5 release. On Fri, May 18, 2018 at 9:26 AM, Till Rohrmann wrote: > Hi everyone, > > since the effective voting period for the RC4 was quite short and it

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Till Rohrmann
Hi everyone, since the effective voting period for the RC4 was quite short and it would be better to give the current RC a bit more exposure, I will extend the voting period for another 72 hours until Monday 6:30pm CET. Cheers, Till On Fri, May 18, 2018 at 4:22 PM, Till Rohrmann wrote: > - Che

[jira] [Created] (FLINK-9400) change import statement for flink-scala

2018-05-18 Thread thinkerou (JIRA)
thinkerou created FLINK-9400: Summary: change import statement for flink-scala Key: FLINK-9400 URL: https://issues.apache.org/jira/browse/FLINK-9400 Project: Flink Issue Type: Improvement

Flink Forward Berlin 2018 - Call for Presentations open until 4th June

2018-05-18 Thread Fabian Hueske
Hi all, Flink Forward returns to Berlin on September 3-5, 2018. We are happy to announce the Call for Presentations is now open! Please submit a proposal if you'd like to present your Apache Flink experience, best practices or use case in front of an international audience of highly skilled and e

[jira] [Created] (FLINK-9399) TPCHQuery3 fails due to Serialization issues

2018-05-18 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9399: --- Summary: TPCHQuery3 fails due to Serialization issues Key: FLINK-9399 URL: https://issues.apache.org/jira/browse/FLINK-9399 Project: Flink Issue Type: Bug Co

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Till Rohrmann
- Checked checksums and GPG files - Verified that source archives do not contain any binaries - Built Flink with Hadoop 2.8.1 and Scala 2.11.7 from source release - Verified LICENSE and NOTICE file: The LICENSE file contains unnecessary entries for jline-reader and jline-terminal - Checked licenses

Re: [DISCUSS] Drop "canEqual" from TypeInformation, TypeSerializer, etc.

2018-05-18 Thread Till Rohrmann
+1 If we don't have a hierarchy of serializers then this method has no right to exist. Cheers, Till On Wed, May 16, 2018 at 11:06 AM, Timo Walther wrote: > +1 > > TypeInformation has too many methods that need to be implemented but > provide little benefit for Flink. > > Am 16.05.18 um 10:55 s

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Piotr Nowojski
+1 From me. I have tested Scala and Java quickstarts and they work fine except of sbt versions. But sbt quickstarts are also failing on my environment for 1.4.x. So it’s either pre-existing issue, or me doing something wrong. I have also run some quick tests on EMR cluster, without problems. Pi

[NOTE] Tracking release notes in the documentation

2018-05-18 Thread Fabian Hueske
Hi everyone, I've collected the release notes for 1.5 (hopefully I didn't miss anything important) and added a page in the documentation [1]. The page is linked from the documentation start page. The page will also be linked from the release announcement and the downloads page. I also added a pag

Re: [VOTE] Release 1.5.0, release candidate #4

2018-05-18 Thread Till Rohrmann
Just a quick correction, I accidentally wrote that the voting period ends tomorrow 5:30pm CET but what I actually meant was today 5:30pm CET. The problem was that I compiled the mail before midnight. Cheers, Till On Fri, May 18, 2018 at 2:50 AM, Till Rohrmann wrote: > Hi everyone, > > Please re