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
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
