Github user danny0405 commented on the issue: https://github.com/apache/storm/pull/2618 @revans2 I did this path for the concurrent race condition on `AsyncLocalize#topologyBlobs` of func: `updateBlobs` and `releaseSlotFor`, `AsyncLocalize#topologyBlobs` overdue keys will be only cleaned by `AsyncLocalize#clean()` timer task, `updateBlobs` is also a timer task but not guarded by lock. I add a RPC api `isRemoteBlobExist` only to let the log not confusing, which is unrelated to this patch.
---