diff --git a/orion-server/src/main/java/com/pinterest/orion/core/actions/memq/MemqTeletraanBrokerDecommissionAction.java b/orion-server/src/main/java/com/pinterest/orion/core/actions/memq/MemqTeletraanBrokerDecommissionAction.java index 4e0bc915..83dcb5f9 100644 --- a/orion-server/src/main/java/com/pinterest/orion/core/actions/memq/MemqTeletraanBrokerDecommissionAction.java +++ b/orion-server/src/main/java/com/pinterest/orion/core/actions/memq/MemqTeletraanBrokerDecommissionAction.java @@ -13,7 +13,7 @@ public abstract class MemqTeletraanBrokerDecommissionAction extends NodeDecommissionAction { private static final int POST_TERMINATION_CHECK_WAIT_TIME_MS = 10_000; // 10 seconds - private static final int TERMINATION_CHECK_TIME_INTERVAL_MS = 300_000; // 5 minutes + private static final int TERMINATION_CHECK_TIME_INTERVAL_MS = 60_000; // 1 minute private static final int TERMINATION_CHECK_TIMEOUT_MS = 1_800_000; // 30 minutes private Logger logger = Logger.getLogger(this.getClass().getName());