Re: Apache Ignite

2015-04-23 Thread sirinath
Any thoughts on this? -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Apache-Ignite-tp5115p5304.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Apache Mahout

2015-04-23 Thread sirinath
Looking to see if Mahout will be integrated as Spark and H2O integration is under way. -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Apache-Mahout-tp5303.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

[jira] [Created] (FLINK-1937) Cannot create SparseVector with only one non-zero element.

2015-04-23 Thread Chiwan Park (JIRA)
Chiwan Park created FLINK-1937: -- Summary: Cannot create SparseVector with only one non-zero element. Key: FLINK-1937 URL: https://issues.apache.org/jira/browse/FLINK-1937 Project: Flink Issue Ty

[jira] [Created] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

2015-04-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1936: --- Summary: Normalize keys and default values in ConfigConstants.java Key: FLINK-1936 URL: https://issues.apache.org/jira/browse/FLINK-1936 Project: Flink

Re: Extracting detailed Flink execution plan

2015-04-23 Thread Stephan Ewen
Okay, nice to hear! Ping us if you run into other trouble... On Thu, Apr 23, 2015 at 2:28 PM, Amit Pawar wrote: > Thanks Stephan. > Using flink-dist jar solves the issue. > > > Thanks and Regards > Amit Pawar > > > On Thu, Apr 23, 2015 at 2:02 PM, Stephan Ewen wrote: > > > Hi! > > > > What you

[jira] [Created] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API

2015-04-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1935: - Summary: Reimplement PersistentKafkaSource using high level Kafka API Key: FLINK-1935 URL: https://issues.apache.org/jira/browse/FLINK-1935 Project: Flink

Re: Extracting detailed Flink execution plan

2015-04-23 Thread Amit Pawar
Thanks Stephan. Using flink-dist jar solves the issue. Thanks and Regards Amit Pawar On Thu, Apr 23, 2015 at 2:02 PM, Stephan Ewen wrote: > Hi! > > What you describe sounds pretty much like a version mixup - NoSuchMethod > indicates one part of the code is out of sync with the other. Can you

Re: Extracting detailed Flink execution plan

2015-04-23 Thread Stephan Ewen
Hi! What you describe sounds pretty much like a version mixup - NoSuchMethod indicates one part of the code is out of sync with the other. Can you make sure that you have all jars from the same Flink version in the classpath? For the Optimizer Exception: The cause may be a similar issue (version

[jira] [Created] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library

2015-04-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1934: Summary: Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library Key: FLINK-1934 URL: https://issues.apache.org/jira/browse/FLINK-1934 Proj