[jira] [Created] (FLINK-1239) Fix iteration example stucking with large input

2014-11-12 Thread JIRA
Gábor Hermann created FLINK-1239: Summary: Fix iteration example stucking with large input Key: FLINK-1239 URL: https://issues.apache.org/jira/browse/FLINK-1239 Project: Flink Issue Type: Bug

Re: Flink Java 8 Lambdas will work again with future Eclipse compilers

2014-11-12 Thread Fabian Hueske
Indeed, thanks for the update! :-) 2014-11-12 20:33 GMT+01:00 Stephan Ewen : > Timo, > > that is great news! Looking forward to the Lambdas working smoothly with > Eclipse / JDT :-) > > Stephan > > > On Wed, Nov 12, 2014 at 6:43 PM, Timo Walther wrote: > > > Hi all, > > > > as some of you may al

Re: Flink Java 8 Lambdas will work again with future Eclipse compilers

2014-11-12 Thread Stephan Ewen
Timo, that is great news! Looking forward to the Lambdas working smoothly with Eclipse / JDT :-) Stephan On Wed, Nov 12, 2014 at 6:43 PM, Timo Walther wrote: > Hi all, > > as some of you may already know, Flink's Java 8 Lambdas currently only > worked if the job has been compiled with the Ecl

Re: HBase 0.98 addon for Flink 0.8

2014-11-12 Thread Flavio Pompermaier
Usually, when I run a mapreduce job both on Spark and Hadoop I just put *-site.xml files into the war I submit to the cluster and that's it. I think the problem appeared when I made the HTable a private transient field and the table istantiation was moved in the configure method. Could it be a vali

Re: HBase 0.98 addon for Flink 0.8

2014-11-12 Thread Robert Metzger
Hi, Maybe its an issue with the classpath? As far as I know is Hadoop reading the configuration files from the classpath. Maybe is the hbase-site.xml file not accessible through the classpath when running on the cluster? On Wed, Nov 12, 2014 at 7:40 PM, Flavio Pompermaier wrote: > Today we tried

Re: HBase 0.98 addon for Flink 0.8

2014-11-12 Thread Flavio Pompermaier
Today we tried tp execute a job on the cluster instead of on local executor and we faced the problem that the hbase-site.xml was basically ignored. Is there a reason why the TableInputFormat is working correctly on local environment while it doesn't on a cluster? On Nov 10, 2014 10:56 AM, "Fabian H

[jira] [Created] (FLINK-1238) Add a way to deactivate the "mutable object safe mode"

2014-11-12 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1238: --- Summary: Add a way to deactivate the "mutable object safe mode" Key: FLINK-1238 URL: https://issues.apache.org/jira/browse/FLINK-1238 Project: Flink Issue Type

Flink Java 8 Lambdas will work again with future Eclipse compilers

2014-11-12 Thread Timo Walther
Hi all, as some of you may already know, Flink's Java 8 Lambdas currently only worked if the job has been compiled with the Eclipse JDT 4.4 compiler because this compiler saves important type information in the class files. Unfortunately, this feature was not officially supported by the Eclipse

[jira] [Created] (FLINK-1237) Add custom partitioners for shuffle steps

2014-11-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1237: Summary: Add custom partitioners for shuffle steps Key: FLINK-1237 URL: https://issues.apache.org/jira/browse/FLINK-1237 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-1236) Add support for localization of Hadoop Input Splits

2014-11-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1236: - Summary: Add support for localization of Hadoop Input Splits Key: FLINK-1236 URL: https://issues.apache.org/jira/browse/FLINK-1236 Project: Flink Issue Typ

[jira] [Created] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration.

2014-11-12 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1235: --- Summary: Compiler rejectes non-nested iterations in constant path of an Iteration. Key: FLINK-1235 URL: https://issues.apache.org/jira/browse/FLINK-1235 Project: Flink

Re: FYI: Talk at the Amsterdam Hadoop User Group

2014-11-12 Thread Robert Metzger
Cool! Its good to see meetup talks about Flink every month now. I've tweeted about it. We do not really have an events page. There was something in the news section recently, but I think a dedicated page for past and upcoming talks would be much better. On Wed, Nov 12, 2014 at 10:27 AM, Stephan

Re: KNIME Integration of Flink

2014-11-12 Thread Arvid Heise
Hi Stephan, Concerning the Amazon images: Amazon provides a facility to add key pairs to their storage. http://docs.aws.amazon.com/gettingstarted/latest/emr/getting-started-emr-setup.html It then initializes the booted image with the keys (details not completely clear). It should be easy to transf

FYI: Talk at the Amsterdam Hadoop User Group

2014-11-12 Thread Stephan Ewen
Hi everyone! We will have a talk on Flink at the next Amsterdam Hadoop User Group meetup. http://www.meetup.com/Netherlands-Hadoop-User-Group/events/218635152/#description-tab Do we still maintain a page with a sample of upcoming events? Also: Did we add the Apache Con talk to the upcoming even