flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mingleizhang <zml13856086...@163.com>
Subject Re:Re: Why does jobmanager running needs slot ?
Date Mon, 05 Feb 2018 09:44:43 GMT
Yes. Thanks Piotrek. Of course. So, TaskExecutor#offerSlotsToJobManager sounds confuse to me.
It might be better to rename it to requestSlotsFromJobManager. I dont know whether it is sounds
OKay for that. I just feel like offerSlotToJobManager sounds strange.. What do you think of
this ?


At 2018-02-05 17:30:32, "Piotr Nowojski" <piotr@data-artisans.com> wrote:
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.


On 5 Feb 2018, at 08:38, mingleizhang <zml13856086071@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.



View raw message