Thanks Benjamin,
I tried to understand the missing reservation metadata and look up relative
docs about resource reservation, however i didn't find to much document about
it.
I solved this problem by adding a method like below in my scheduler:
def luanchtask(offer: Offer, task: TaskInfo): Call = {
Call.newBuilder()
.setFrameworkId(frameworkId)
.setType(Call.Type.ACCEPT)
.setAccept(
Call.Accept.newBuilder()
.addOfferIds(offer.getId)
.addOperations(
Offer.Operation.newBuilder()
.setType(Offer.Operation.Type.LAUNCH)
.setLaunch(
Offer.Operation.Launch.newBuilder()
.addTaskInfos(task)))).build()
}
And after that I met another problem: my task is always in staging, and
terminates after 1min due to timeout. I think there are many mini process in a
scheduler app including callbacks, such as connect, register, get offers
list,accpet offer and etc. Is there a detail programming guide in V1 framework
developing?
Thank you.
San
________________________________
发件人: Benjamin Mahler <[email protected]>
发送时间: 2018年3月10日 9:00:55
收件人: user
主题: Re: 答复: Status update: task 1 is in state TASK_ERROR
The message clarifies it, the task+executor have some unreserved resources:
cpus(allocated: controller):6; mem(allocated: controller):8000
But the resources offered were reserved:
cpus(allocated: controller)(reservations: [(STATIC,controller)]):6;
mem(allocated: controller)(reservations: [(STATIC,controller)]):8000; + disk +
ports
The scheduler needs to provide resources that are contained in the offer, in
this case it needs to include the missing reservation metadata.
On Thu, Mar 8, 2018 at 6:57 PM, 罗 辉
<[email protected]<mailto:[email protected]>> wrote:
yes,I modified my code like below:
def acknowledgeTaskMessage(taskStatus: TaskStatus): String = {
taskStatus.getMessage
}
def update(mesos: Mesos, status: TaskStatus) = {
val message = acknowledgeTaskMessage(status)
println("The message of current task is :" + message)
println("Status update: task " + status.getTaskId().getValue() + " is in
state " + status.getState().getValueDescriptor().getName())
......
And I got below log as attched file line 231:
231 Received an UPDATE event
232 The message of current task is :Total resources cpus(allocated:
controller):6; mem(allocated: controller):8000 required by task and its
executor is more than available cpus(allocated: controller)(reservations:
[(STATIC,controller)]):6; mem(allocated: controller) (reservations:
[(STATIC,controller)]):8000; disk(allocated: controller)(reservations:
[(STATIC,controller)]):550264; ports(allocate d: controller):[31000-32000]
233 Status update: task 1 is in state TASK_ERROR
罗辉
基础架构
________________________________
发件人: Benjamin Mahler <[email protected]<mailto:[email protected]>>
发送时间: 2018年3月9日 9:24:37
收件人: user
主题: Re: Status update: task 1 is in state TASK_ERROR
Can you log the message provided in the TaskStatus?
https://github.com/apache/mesos/blob/1.5.0/include/mesos/v1/mesos.proto#L2424
[https://avatars3.githubusercontent.com/u/47359?s=400&v=4]<https://github.com/apache/mesos/blob/1.5.0/include/mesos/v1/mesos.proto#L2424>
apache/mesos<https://github.com/apache/mesos/blob/1.5.0/include/mesos/v1/mesos.proto#L2424>
github.com
mesos - Mirror of Apache Mesos
On Wed, Mar 7, 2018 at 11:23 PM, 罗 辉
<[email protected]<mailto:[email protected]>> wrote:
Hi guys:
I got a mesos test app, mostly likely
https://github.com/apache/mesos/blob/master/src/java/src/org/apache/mesos/v1/scheduler/V1Mesos.java
[https://avatars3.githubusercontent.com/u/47359?s=400&v=4]<https://github.com/apache/mesos/blob/master/src/java/src/org/apache/mesos/v1/scheduler/V1Mesos.java>
apache/mesos<https://github.com/apache/mesos/blob/master/src/java/src/org/apache/mesos/v1/scheduler/V1Mesos.java>
github.com
mesos - Mirror of Apache Mesos
just to run a simple task "free -m". The app can not run the task successfully,
always got a log info :
Received an UPDATE event
Status update: task 1 is in state TASK_ERROR
I checked the logs , but no Errors in the mesos-master.ERROR or
mesos-agent.ERROR, only in mesos-master.INFO shows :
W0307 17:55:28.180716 29438 validation.cpp:1298] Executor 'default' for task
'1' uses less CPUs (None) than the minimum required (0.01). Please update your
executor, as this will be mandatory in future releases.
W0307 17:55:28.180766 29438 validation.cpp:1310] Executor 'default' for task
'1' uses less memory (None) than the minimum required (32MB). Please update
your executor, as this will be mandatory in future releases.
Following this log, I didn't find a way to set the executor's resource or
similar code example
Why my little app always fails? Thanks for any ideas.
San
