c9d33bc82cfbb741542d00131ebf8a4790f4df15 - storm

commit	c9d33bc82cfbb741542d00131ebf8a4790f4df15	[log] [tgz]
author	agresch <agresch@gmail.com>	Tue Jan 12 10:00:44 2021 -0600
committer	GitHub <noreply@github.com>	Tue Jan 12 10:00:44 2021 -0600
tree	50f2aed2d29c07207dfe24fef0479b3f51affc30
parent	7207cc883c71061a522ccaba33bf29fb5003282f [diff]

STORM-3733 fix AsyncLocalizer from updating dead topology blobs (#3370)

* STORM-3733 add logging to debug AsyncLocalizer looking for dead topology

* STORM-3733 check for equivalent pna's when removing references from LocallyCachedBlob

* STORM-3733 handle potential NPE

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java[diff]
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java[diff]
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java[diff]
storm-server/src/main/java/org/apache/storm/localizer/PortAndAssignment.java[diff]
storm-server/src/main/java/org/apache/storm/utils/EquivalenceUtils.java[Added - diff]
storm-server/src/test/java/org/apache/storm/daemon/supervisor/SlotTest.java[diff]
storm-server/src/test/java/org/apache/storm/localizer/LocalizedResourceRetentionSetTest.java[diff]
storm-server/src/test/java/org/apache/storm/utils/EquivalenceUtilsTest.java[Added - diff]

8 files changed