Jagadish created SAMZA-1699:
-------------------------------
Summary: NPE in ClusterResourceManager
Key: SAMZA-1699
URL: https://issues.apache.org/jira/browse/SAMZA-1699
Project: Samza
Issue Type: Bug
Reporter: Jagadish
When the ClusterResourcedManager receives a notification that a container is
started, it moves the container from the "pending queue" to its "running queue".
In the meanwhile, it's possible for another thread to remove the mapping for
the key. Here's an example:
NMCallbackThread-1:pendingYarnContainers.remove(key);
NMCallbackThread-2:
for (String key : pendingYarnContainers.keySet()) {
yarnContainer = pendingYarnContainers.get(key); <-- could be null depending
on whether the removal happened before it.
}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
