Re: [ANNOUNCE] Apache Flink 1.3.3 released

2018-03-20 Thread Philip Luppens
Hi everyone, Thanks, but I don’t see the binaries for 1.3.3 being pushed anywhere in the Maven repositories [1]. Can we expect them to show up over there as well eventually? [1] https://repo.maven.apache.org/maven2/org/apache/flink/flink-java/ Kind regards, -Phil On Fri, Mar 16, 2018 at 3:36

Re: Flink Kinesis Consumer re-reading merged shards upon restart

2018-01-23 Thread Philip Luppens
Hi Gordon, I’ve created a PR [1] with my proposed code changes. Let me know if anything is missing. I think I signed a CLA many years ago, so that should be ok as well. [1] https://github.com/apache/flink/pull/5337 HTH, -Phil On Mon, Jan 22, 2018 at 7:17 PM, Philip Luppens wrote: >

Re: Flink Kinesis Consumer re-reading merged shards upon restart

2018-01-22 Thread Philip Luppens
was running. > > Your workaround is also a valid fix for this bug. Could you file a JIRA > for this? Would be happy to also review a PR for the fix, if you would like > to contribute it. > > Cheers, > Gordon > > > On 22 January 2018 at 5:08:36 PM, Philip Luppens (philip.l

Flink Kinesis Consumer re-reading merged shards upon restart

2018-01-22 Thread Philip Luppens
Hi everyone, For the past weeks, we’ve been struggling with Kinesis ingestion using the Flink Kinesis connector, but the seemingly complete lack of similar reports makes us wonder if perhaps we misconfigured or mis-used the connector. We’re using the connector to subscribe to streams varying from