RuiLi8080 opened a new pull request #3336: URL: https://github.com/apache/storm/pull/3336
## What is the purpose of the change When AsyncLocalizer cleanup happens, make sure it check against the latest topology cache information. Currently, the `safeTopologyIds` set might become stale due to delay at around https://github.com/apache/storm/blob/master/storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java#L641 . Newly created topology entries might not appear here and clean-up will delete them by fault and cause further FNF issue. ## How was the change tested Reproduce the FNF issue with additional sleep. After the change, same delay won't cause the FNF anymore. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
