flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From MaGuoWei <maguo...@outlook.com>
Subject A Question About Execution Schedule
Date Wed, 19 Aug 2015 03:45:10 GMT
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 scheduler can't get the future
action.
Please let me know If I am wrong .
Thanks. 		 	   		  
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message