[ISSUE-158][BUG] When revive meet reserve slot filed, will throw ArrayBoundOutOfIndex exception (#159)

AngersZhuuuu · web-flow · commit 84a281ff8918 · 2022-06-23T16:15:38.000+08:00
* [ISSUE-158][BUG] When revive meet reserve slot filed, will throw ArrayBoundOutOfIndex exception

* Update pom.xml
diff --git a/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala b/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala
@@ -897,6 +897,10 @@ class LifecycleManager(appId: String, val conf: RssConf) extends RpcEndpoint wit
                 slavePartitionLocations.remove(partition)
                 destroyResource.computeIfAbsent(workerInfoWithRpcRef, newMapFunc)._2.add(partition)
               }
+              if (slots.containsKey(workerInfoWithRpcRef) && masterPartitionLocations.isEmpty &&
+                slavePartitionLocations.isEmpty) {
+                slots.remove(workerInfoWithRpcRef)
+              }
             }
           })
           if (!destroyResource.isEmpty) {

Original file line number	Diff line number	Diff line change
`@@ -897,6 +897,10 @@ class LifecycleManager(appId: String, val conf: RssConf) extends RpcEndpoint wit`
`897`	`897`	`slavePartitionLocations.remove(partition)`
`898`	`898`	`destroyResource.computeIfAbsent(workerInfoWithRpcRef, newMapFunc)._2.add(partition)`
`899`	`899`	`}`
	`900`	`+ if (slots.containsKey(workerInfoWithRpcRef) && masterPartitionLocations.isEmpty &&`
	`901`	`+ slavePartitionLocations.isEmpty) {`
	`902`	`+ slots.remove(workerInfoWithRpcRef)`
	`903`	`+ }`
`900`	`904`	`}`
`901`	`905`	`})`
`902`	`906`	`if (!destroyResource.isEmpty) {`