From ac146f8961f04d4e48ef9085e46d85f05c85a850 Mon Sep 17 00:00:00 2001
From: Andrei Nadyktov <nadyktov.a.s@sbertech.ru>
Date: Wed, 3 Jun 2026 21:13:44 +0300
Subject: [PATCH] IGNITE-28744 Add check of cluster state for cdc resend
 command

---
 .../internal/management/cdc/CdcCacheDataResendTask.java      | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcCacheDataResendTask.java b/modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcCacheDataResendTask.java
index 9858331492b8f..00b51853f3085 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcCacheDataResendTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcCacheDataResendTask.java
@@ -50,6 +50,7 @@
 import org.apache.ignite.resources.LoggerResource;
 import org.jetbrains.annotations.Nullable;
 
+import static org.apache.ignite.cluster.ClusterState.INACTIVE;
 import static org.apache.ignite.internal.util.lang.ClusterNodeFunc.nodeIds;
 
 /**
@@ -71,6 +72,10 @@ public class CdcCacheDataResendTask extends VisorMultiNodeTask<CdcResendCommandA
 
     /** {@inheritDoc} */
     @Override protected Collection<UUID> jobNodes(VisorTaskArgument<CdcResendCommandArg> arg) {
+        // Check if cluster is inactive.
+        if (ignite.cluster().state() == INACTIVE)
+            throw new IgniteException("CDC cache data resend cancelled. Cluster is inactive.");
+
         // Check there is no rebalance.
         GridDhtPartitionsExchangeFuture fut = ignite.context().cache().context().exchange().lastFinishedFuture();