flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Execution graph
Date Tue, 30 Jun 2015 08:25:03 GMT
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.


On Tue, Jun 30, 2015 at 7:11 AM, Michele Bertoni <
michele1.bertoni@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

View raw message