}
assignments.put(topologyId, assignment);
Map<Integer, String> lastErrTimeStamp = null;
try {
lastErrTimeStamp = stormClusterState.topo_lastErr_time(topologyId);
} catch (Exception e) {
LOG.error("Failed to get last error timestamp map for "+ topologyId +
", and begin to remove the corrupt data", e);
try {
stormClusterState.remove_lastErr_time(topologyId);