[TEZ-3956] testTaskSchedulerPreemption test fails intermittently - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Open
Priority: Major
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

Error Message

Wanted but not invoked:
tezAMRMClientAsync.releaseAssignedContainer(
<any>
);
-> at org.apache.tez.dag.app.rm.TestTaskScheduler.testTaskSchedulerPreemption(TestTaskScheduler.java:1197)

However, there were other interactions with this mock:
tezAMRMClientAsync.init(Configuration: );
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.initialize(YarnTaskSchedulerService.java:281)

tezAMRMClientAsync.setHeartbeatInterval(
1000
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.initialize(YarnTaskSchedulerService.java:285)

tezAMRMClientAsync.start();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.start(YarnTaskSchedulerService.java:365)

tezAMRMClientAsync.registerApplicationMaster(
"host",
0,
"url"
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.start(YarnTaskSchedulerService.java:366)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getAvailableResources(YarnTaskSchedulerService.java:257)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[2]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getMatchingRequests(
2,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[2]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
6,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
6,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
2,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[8]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

Stacktrace

org.mockito.exceptions.verification.WantedButNotInvoked: 
Wanted but not invoked:
tezAMRMClientAsync.releaseAssignedContainer(
<any>
);
-> at org.apache.tez.dag.app.rm.TestTaskScheduler.testTaskSchedulerPreemption(TestTaskScheduler.java:1197)

However, there were other interactions with this mock:
tezAMRMClientAsync.init(Configuration: );
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.initialize(YarnTaskSchedulerService.java:281)

tezAMRMClientAsync.setHeartbeatInterval(
1000
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.initialize(YarnTaskSchedulerService.java:285)

tezAMRMClientAsync.start();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.start(YarnTaskSchedulerService.java:365)

tezAMRMClientAsync.registerApplicationMaster(
"host",
0,
"url"
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.start(YarnTaskSchedulerService.java:366)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getAvailableResources(YarnTaskSchedulerService.java:257)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[2]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getMatchingRequests(
2,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"host1",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
6,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"/default-rack",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.getMatchingRequests(
2,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[2]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
6,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
6,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getMatchingRequests(
2,
"*",
<memory:1024, vCores:1>
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.getMatchingRequestWithPriority(YarnTaskSchedulerService.java:1453)

tezAMRMClientAsync.removeContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.removeTaskRequest(YarnTaskSchedulerService.java:1641)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.addContainerRequest(
Capability[<memory:1024, vCores:1>]Priority[8]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}]
);
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.addTaskRequest(YarnTaskSchedulerService.java:1653)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)

tezAMRMClientAsync.getAvailableResources();
-> at org.apache.tez.dag.app.rm.YarnTaskSchedulerService.preemptIfNeeded(YarnTaskSchedulerService.java:1171)


at org.apache.tez.dag.app.rm.TestTaskScheduler.testTaskSchedulerPreemption(TestTaskScheduler.java:1197)
Standard Output

2018-06-19 18:52:30,283 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:initialize(346)) - YarnTaskScheduler initialized with configuration: maxRMHeartbeatInterval: 1000, containerReuseEnabled: false, reuseRackLocal: true, reuseNonLocal: false, localitySchedulingDelay: 250, preemptionPercentage: 10, preemptionMaxWaitTime: 60000, numHeartbeatsBetweenPreemptions: 3, idleContainerMinTimeout: 5000, idleContainerMaxTimeout: 10000, sessionMinHeldContainers: 0
2018-06-19 18:52:30,290 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:getProgress(908)) - App total resource memory: 4000 cpu: 4 taskAllocations: 0
2018-06-19 18:52:30,291 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:preemptIfNeeded(1176)) - Allocated: <memory:0, vCores:0> Free: <memory:4000, vCores:4> pendingRequests: 0 delayedContainers: 0 heartbeats: 1 lastPreemptionHeartbeat: 0
2018-06-19 18:52:30,299 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: task1 with request: Capability[<memory:1024, vCores:1>]Priority[2]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,299 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: task3 with request: Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,300 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: task3KillA with request: Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,303 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: task3KillB with request: Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,319 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:doBookKeepingForAssignedContainer(1835)) - Assigning container to task: containerId=container_1_0001_01_000001, task=task1, containerHost=host1:1, containerPriority= 2, containerResources=<memory:1024, vCores:1>, localityMatchType=NonLocal, matchedLocation=*, honorLocalityFlags=false, reusedContainer=false, delayedContainers=0
2018-06-19 18:52:30,320 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:doBookKeepingForAssignedContainer(1835)) - Assigning container to task: containerId=container_1_0001_01_000002, task=task3, containerHost=host1:1, containerPriority= 6, containerResources=<memory:1024, vCores:1>, localityMatchType=NonLocal, matchedLocation=*, honorLocalityFlags=false, reusedContainer=false, delayedContainers=0
2018-06-19 18:52:30,320 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:doBookKeepingForAssignedContainer(1835)) - Assigning container to task: containerId=container_1_0001_01_000003, task=task3KillA, containerHost=host1:1, containerPriority= 6, containerResources=<memory:1024, vCores:1>, localityMatchType=NonLocal, matchedLocation=*, honorLocalityFlags=false, reusedContainer=false, delayedContainers=0
2018-06-19 18:52:30,321 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:doBookKeepingForAssignedContainer(1835)) - Assigning container to task: containerId=container_1_0001_01_000004, task=task3KillB, containerHost=host1:1, containerPriority= 2, containerResources=<memory:1024, vCores:1>, localityMatchType=NonLocal, matchedLocation=*, honorLocalityFlags=false, reusedContainer=false, delayedContainers=0
2018-06-19 18:52:30,327 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: task3Wait with request: Capability[<memory:1024, vCores:1>]Priority[6]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,327 INFO [Thread-3] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:addRequestAndTrigger(1014)) - Allocation request for task: taskPri8 with request: Capability[<memory:1024, vCores:1>]Priority[8]AllocationRequestId[0]ExecutionTypeRequest[{Execution Type: GUARANTEED, Enforce Execution Type: false}] host: null rack: null
2018-06-19 18:52:30,331 INFO [DelayedContainerManager] rm.YarnTaskSchedulerService (YarnTaskSchedulerService.java:doAssignAll(2097)) - AssignAll - Skipping delayed container as container is no longer running, containerId=container_1_0001_01_000005

Attachments

Issue Links

Blocked

TEZ-3934 LegacySpeculator sometime issues wrong number of speculative attempts

Closed

Activity

People

Assignee:: Unassigned

Reporter:: Nishant Dash

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Dates

Created:: 19/Jun/18 22:07

Updated:: 19/Jun/18 22:08