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 jobNodes(VisorTaskArgument 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();