[DISCUSS] Mesos version dependency

Hello, For Flink's initial support for Mesos, coming in Flink 1.2, does anyone have an objection to making the minimum requirement be Mesos 1.0+? There are some functional benefits to 1.0 and it would simplify the test effort. ThanksEron Wright

[jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction

Greg Hogan created FLINK-4729: - Summary: Use optional VertexCentric CombineFunction Key: FLINK-4729 URL: https://issues.apache.org/jira/browse/FLINK-4729 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4728) Replace reference equality with object equality

Greg Hogan created FLINK-4728: - Summary: Replace reference equality with object equality Key: FLINK-4728 URL: https://issues.apache.org/jira/browse/FLINK-4728 Project: Flink Issue Type:

Duplicate sort keys

Is it correct to expect that Flink should remove duplicate sort keys? I'm working on instrumenting the FixedLengthRecordSorter (FLINK-4705) and the following test case from TypeHintITCase:200 is having an unexpected effect due to the keyPositions = {0, 0} being passed to TupleComparator. DataSet

Re: Assign issue

Sure, Nikolay. Thanks for your willingness to contribute to Flink. I have added you to the project, next time you can do it yourself. Best, Marton On Mon, Oct 3, 2016 at 11:33 AM, Nikolay Vasilishin < nikolay_vasilis...@epam.com> wrote: > Hi devs. > > I'd like to do something for flink. Could

Assign issue

Hi devs. I'd like to do something for flink. Could you assign https://issues.apache.org/jira/browse/FLINK-3204 for me in JIRA? Thanks in advance, Nikolay Vasilishin Junior Software Engineer Office: +7 812 611 10 94 x 61997 Cell: +7 921 403 78

Using Flink

Hi, I have few questions on how I need to model my use case in flink. Please advise. Thanks for the help. - I'm currently running my flink program on 1.2 SNAPSHOT with kafka source and I have checkpoint enabled. When I look at the consumer offsets in kafka it appears to be stagnant and there