Re: flink-storm FlinkLocalCluster issue

2016-02-29 Thread Maximilian Michels
wrote: > Thanks for the confirmation. > > When will 1.0 be ready in maven repo? > > > > From: ewenstep...@gmail.com [mailto:ewenstep...@gmail.com] On Behalf Of > Stephan Ewen > Sent: Friday, February 26, 2016 9:07 PM > To: user@flink.apache.org > Subject:

RE: flink-storm FlinkLocalCluster issue

2016-02-26 Thread #ZHANG SHUHAO#
Thanks for the confirmation. When will 1.0 be ready in maven repo? From: ewenstep...@gmail.com [mailto:ewenstep...@gmail.com] On Behalf Of Stephan Ewen Sent: Friday, February 26, 2016 9:07 PM To: user@flink.apache.org Subject: Re: flink-storm FlinkLocalCluster issue Hi! On 0.10.x, the Storm

Re: flink-storm FlinkLocalCluster issue

2016-02-26 Thread Stephan Ewen
Hi! On 0.10.x, the Storm compatibility layer does not properly configure the Local Flink Executor to have the right parallelism. In 1.0 that is fixed. If you try the latest snapshot, or the 1.0-Release-Candidate-1, it should work. Greetings, Stephan On Fri, Feb 26, 2016 at 12:16 PM, #ZHANG

Re: flink-storm FlinkLocalCluster issue

2016-02-26 Thread #ZHANG SHUHAO#
Hi till, Thanks for your reply. But it appears that it only started with #slot of 1. I have traced down to the source code of flink step by step, where I have confirmed it. I'm using flink 0.10.2, source code downloaded from flink website. Nothing have been changed. I simply try to run the

Re: flink-storm FlinkLocalCluster issue

2016-02-26 Thread Till Rohrmann
Hi Shuhao, the configuration you’re providing is only used for the storm compatibility layer and not Flink itself. When you run your job locally, the LocalFlinkMiniCluster should be started with as many slots as your maximum degree of parallelism is in your topology. You can check this in

flink-storm FlinkLocalCluster issue

2016-02-26 Thread #ZHANG SHUHAO#
Hi everyone, I'm a student researcher working on Flink recently. I'm trying out the flink-storm example project, version 0.10.2, flink-storm-examples, word-count-local. But, I got the following error: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Not enough free