Hi Michele, If you don't set the parallelism, the default parallelism is used. For the visualization in the web client, a parallelism of one is used. When you run your example from your IDE, the default parallelism is set to the number of (virtual) cores of your CPU.
Moreover, Flink will currently not automatically set the parallelism in a cluster environment. It will use the default parallelism or the user-set parallelism. In your example, if you set the parallelism explicitly then it will also show up in the visualization. Best, Max On Tue, Jun 30, 2015 at 7:11 AM, Michele Bertoni < michele1.bert...@mail.polimi.it> wrote: > Hi, I was trying to run my program in the flink web environment (the local > one) > when I run it I get the graph of the planned execution but in each node > there is a "parallelism = 1”, instead i think it runs with par = 8 (8 core, > i always get 8 output) > > what does that mean? > is that wrong or is it really running with 1 degree of par? > > just a note: I never do any setParallelism() command, i leave it > automatical > > thanks > Best > Michele
