Skip to content

Commit 4ef1ba1

Browse files
hellolittlejggao
andauthored
Disable loading expired disableTE request on bootstrap (#807)
Co-authored-by: ggao <ggao@netflix.com>
1 parent 4be9cc3 commit 4ef1ba1

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,10 +229,15 @@ public void preStart() throws Exception {
229229

230230
fetchJobArtifactsToCache();
231231

232+
final Instant now = clock.instant();
232233
List<DisableTaskExecutorsRequest> activeRequests =
233234
mantisJobStore.loadAllDisableTaskExecutorsRequests(clusterID);
234235
for (DisableTaskExecutorsRequest request : activeRequests) {
235-
onNewDisableTaskExecutorsRequest(request);
236+
if (!request.isExpired(now)) {
237+
onNewDisableTaskExecutorsRequest(request);
238+
} else {
239+
onDisableTaskExecutorsRequestExpiry(new ExpireDisableTaskExecutorsRequest(request));
240+
}
236241
}
237242

238243
timers().startTimerWithFixedDelay(

0 commit comments

Comments
 (0)