org.apache.flink.runtime.jobmaster.JobMaster#offerSlots is a receiver side of an RPC call that is being initiated on the sender side: org.apache.flink.runtime.taskexecutor.TaskExecutor#offerSlotsToJobManager.
In other words, JobMasterGateway.offerSlots is called by a TaskManager and it is a way how TaskManager is advertising his slots to a JobManager. Piotrek > On 5 Feb 2018, at 08:38, mingleizhang <zml13856086...@163.com> wrote: > > I find some codes in flink does not make sense to me. Like in some classes > below > > JobMasterGateway.java has a offerSlots method which means Offers the given > slots to the job manager. I was wondering why a jobmanager running should > need slots ? > TaskExecutor.java has a offerSlotsToJobManager method which means offer slots > to jobmanager. > > Above both are confuse me. I just know that Task running needs slots which > support by a taskManager. Does anyone let me why what does jobmanager needs > slots mean ? > > Thanks in advance. > Rice. > > > > >
