Cannot run Storm WordCountLocal

2015-10-07 Thread Matthias J. Sax
Hi, I cannot run WordCountLocal example of flink-storm-example in Eclipse. The ITCase for it works, but it is using a test environment. If I start WordCountLocal directly it uses FlinkMiniCluster and I get the following exception: > org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailabl

Re: Cannot run Storm WordCountLocal

2015-10-07 Thread Stephan Ewen
The mini cluster is started with not enough slots. I would guess that it is luck that the IT case works because the test environment probably uses a simple default of 4 slots or so for the mini cluster. The LocalEnvironment in the DataSet API actually makes a pass over the operators to see how man