Re: Default parallelism for job submitted using RemoteEnvironment

2015-12-04 Thread Maximilian Michels
Hi Kien Truong, This behavior is intentional. The "parallelism.default" config entry refers to the default parallelism to set when submitting Flink programs. Since Flink programs are assembled on the Client (your machine) it is set to 1 there. When you submit from the cluster, it picks up the corr

Default parallelism for job submitted using RemoteEnvironment

2015-12-03 Thread Truong Duc Kien
Hi, When I submit a job using RemoteEnvironment without setting parallelism, it always uses only one task slot. Is this a bug or intentional ? I thought it was supposed to be the default configuration of the server (parallelism.default=24 in my cases) I'm using Flink in Standalone cluster mode.