Re: Flink ML source code

2015-09-11 Thread Till Rohrmann
Hi Hanan, if you need any help implementing ANOVA, then let me know. I'd like to assist you. Cheers, Till On Thu, Sep 10, 2015 at 4:15 PM, Robert Metzger wrote: > Hi, > > you can find the Flink ML source code here: > https://github.com/apache/flink/tree/master/flink-staging/flink-ml > > On Thu

[jira] [Created] (FLINK-2658) fieldsGrouping for multiple output streams fails

2015-09-11 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2658: -- Summary: fieldsGrouping for multiple output streams fails Key: FLINK-2658 URL: https://issues.apache.org/jira/browse/FLINK-2658 Project: Flink Issue Type

Re: Flink ML source code

2015-09-11 Thread Hanan Meyer
Thanks all for the fast response ! I'll check the code in order to plan out development and inform you . We may need some advise for it .. Thanks' Hanan On Fri, Sep 11, 2015 at 11:12 AM, Till Rohrmann wrote: > Hi Hanan, > > if you need any help implementing ANOVA, then let me know. I'd like

Re: Releasing 0.10.0-milestone1

2015-09-11 Thread Matthias J. Sax
I would have an important fix too. https://issues.apache.org/jira/browse/FLINK-2658 https://github.com/apache/flink/pull/1122 Or is it too late? On 09/10/2015 06:54 PM, Robert Metzger wrote: > Since the vote has not been started yet, we might consider including this > critical fix for the Kafka

Re: Releasing 0.10.0-milestone1

2015-09-11 Thread Stephan Ewen
Fixes come up on a daily base. I think at some point we need to declare freeze, or this thing will never be released. @Fabian: Since you are release manager, do you want to pick the point to declare freeze (and pick what should be included)? On Fri, Sep 11, 2015 at 2:41 PM, Matthias J. Sax wrote

Re: Releasing 0.10.0-milestone1

2015-09-11 Thread Fabian Hueske
We're waiting for a fix of FLINK-2637 (TypeInfo equals + hashcode). Once this is in, we do the first release candidate, OK? 2015-09-11 14:48 GMT+02:00 Stephan Ewen : > Fixes come up on a daily base. I think at some point we need to declare > freeze, or this thing will never be released. > > @Fabi

Re: Releasing 0.10.0-milestone1

2015-09-11 Thread Stephan Ewen
Sure that is fine with me you are the release manager ;-) I don't want to say let's not include anything else, just saying that we need a cutoff point, as we have been postponing this for a while... On Fri, Sep 11, 2015 at 2:51 PM, Fabian Hueske wrote: > We're waiting for a fix of FLINK-2637 (T

[jira] [Created] (FLINK-2659) Object reuse in UnionWithTempOperator

2015-09-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2659: - Summary: Object reuse in UnionWithTempOperator Key: FLINK-2659 URL: https://issues.apache.org/jira/browse/FLINK-2659 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0

2015-09-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2660: --- Summary: Yarn Tests fail with Hadoop 2.3.0 Key: FLINK-2660 URL: https://issues.apache.org/jira/browse/FLINK-2660 Project: Flink Issue Type: Bug

Does flink support groupByKey([numTasks])

2015-09-11 Thread Liang Chen
Hi Now i am considering migrate Sparkstreaming case to Flink for comparing performance. Does flink support groupByKey([numTasks]) ,When called on a dataset of (K, V) pairs, returns a dataset of (K, Iterable) pairs. If it is not exist, how to use groupBy() to implement the same function? --