Hi,
Could you maybe send a screenshot from the dashboard that shows how tasks are
being assigned to slots?
Aljoscha
> On 4. Mar 2018, at 18:06, vijayakumar palaniappan
> wrote:
>
> I am using flink 1.4.0 in standalone cluster mode
>
> I have a job with a graph like a Source(parallelism 3) -
I am using flink 1.4.0 in standalone cluster mode
I have a job with a graph like a Source(parallelism 3) ->
Filter(parallelism 3) -> Map(parallelism 1) -> sink(parallelism 3)
As per the understanding, max number of tasks slots should be bounded by
the max parallelism, which in this case is 3.
Th
Hi Vinay,
try to set the parallelism to 2 for the job you are executing via the
RemoteExecutionEnvironment.
Where have you specified the number of TaskManager slots? In the
flink-conf.yaml file which you used to deploy the remote Flink cluster?
Cheers,
Till
On Fri, Feb 16, 2018 at 7:14 PM, Vina
Hi,
I am trying to deploy a flink job to remote cluster using
remoteExecutionEnvironment, I have specified the number of task slots for
Task Manager to 2 , so it should have ideally taken 2 slots only, however
all the slots are getting utilized. Is there any other configuration I have
to do ?
Reg
