Skip to content

Commit d838fd1

Browse files
author
Michael Askndafi
committed
Skip if no longer leader
1 parent 4d579c4 commit d838fd1

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

services/venice-controller/src/main/java/com/linkedin/venice/controller/DeadStoreStatsPreFetchTask.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,12 @@ public void run() {
5959
while (isRunning.get()) {
6060
try {
6161
Utils.sleep(refreshIntervalMs);
62+
63+
// Check if controller is still the leader before fetching stats
64+
if (!admin.isLeaderControllerFor(clusterName)) {
65+
continue;
66+
}
67+
6268
long startTime = System.currentTimeMillis();
6369
logger.debug("Fetching dead store stats for cluster: {}", clusterName);
6470
admin.preFetchDeadStoreStats(clusterName, getStoresInCluster());

0 commit comments

Comments
 (0)