Hi Daniel
Your problem did get solved, I assume.
As for the -p flag, it determines the default parallelism of operators at
runtime. If you end up specifying a value more than the slots available,
that's an issue. Hope that helped.
Cheers
Sachin
On Sep 13, 2015 9:13 PM, "Daniel Blazevski"
wrote:
Hello,
I am not sure if I can give updates to an email I send to the user list
before getting any response, but here is a quick update:
I tried to run using one processor:
./bin/flink run -p 1 ./examples/flink-java-examples-0.9.1-WordCount.jar
and that worked. It seems to be an issue with confi
Hello,
I am new to Flink, I setup a Flink cluster on 4 m4.large Amazon EC2 instances,
and set the following in link-conf.yaml:
jobmanager.heap.mb: 4000
taskmanager.heap.mb: 5000
taskmanager.numberOfTaskSlots: 2
parallelism.default: 8
In the 8081 dashboard, it shows 4 for Task Manager and 5 for
