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.


---

Reply via email to