Skip to content

Commit e246c3c

Browse files
authored
Merge pull request #2262 from HubSpot/fix-decommissioned-task-npe
Fix npe for tasks with null hostnames from decommissioned host resources
2 parents 70b724e + 661dfc4 commit e246c3c

2 files changed

Lines changed: 2 additions & 13 deletions

File tree

SingularityService/src/main/java/com/hubspot/singularity/mesos/SingularityAgentAndRackManager.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -800,18 +800,7 @@ public void checkDecommissionedAgentsFromMaster(
800800

801801
for (MesosMasterAgentObject agentJsonObject : state.getAgents()) {
802802
String agentId = agentJsonObject.getId();
803-
if (agentsById.containsKey(agentId)) {
804-
SingularityAgent agent = agentsById.get(agentId);
805-
if (agent != null) {
806-
LOG.info(
807-
"Found resources ({}) for decommissioned agent {}",
808-
agentJsonObject.getResources(),
809-
agent
810-
);
811-
agentManager.saveObject(agent.withResources(agentJsonObject.getResources()));
812-
}
813-
agentsById.remove(agentId);
814-
}
803+
agentsById.remove(agentId);
815804
}
816805

817806
for (SingularityAgent leftOverAgent : agentsById.values()) {

SingularityService/src/main/java/com/hubspot/singularity/mesos/SingularityStartup.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,8 @@ public void startup(MasterInfo masterInfo) {
108108

109109
MesosMasterStateObject state = mesosClient.getMasterState(uri);
110110

111-
agentAndRackManager.loadAgentsAndRacksFromMaster(state, true);
112111
agentAndRackManager.checkDecommissionedAgentsFromMaster(state, true);
112+
agentAndRackManager.loadAgentsAndRacksFromMaster(state, true);
113113

114114
ExecutorService startupExecutor = Executors.newFixedThreadPool(
115115
configuration.getSchedulerStartupConcurrency(),

0 commit comments

Comments
 (0)