Thanks Till!
> Date: Wed, 19 Aug 2015 09:31:49 +0200
> Subject: Re: A Question About Execution Schedule
> From: trohrm...@apache.org
> To: dev@flink.apache.org
>
> Hi MaGuoWei,
>
> this is not a problem. If you look at the implementation of
> SlotAllocationFuture.setFu
Hi MaGuoWei,
this is not a problem. If you look at the implementation of
SlotAllocationFuture.setFutureAction, you’ll see that the method is
synchronized on a lock which is also used to complete the future.
Furthermore, you’ll see that the slot variable is checked upon setting an
action and if it’
Hi,guysThere are some codes in scheduleForExecution Function in Execution.java:
1. SlotAllocationFuture future = scheduler.scheduleQueued(toSchedule); 2.
future.setFutureAction(new SlotAllocationFutureAction() {..})
When scheduler finds some slot between line1 and line 2 the sc
