From f0f70db3426f7e23d71107b94f65e675ea7cc980 Mon Sep 17 00:00:00 2001
From: yrizhkov <yrizhkov@aerospike.com>
Date: Mon, 1 Jul 2024 09:58:25 +0300
Subject: [PATCH] FMWK-484 Add node activity filter to monitor method

---
 .../com/aerospike/client/reactor/AerospikeReactorClient.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java b/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java
index 420d293..ccb990e 100644
--- a/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java
+++ b/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java
@@ -418,6 +418,7 @@ private Mono<AsyncIndexTask> dropIndexImpl(Policy policy,
 	private Mono<Void> waitTillComplete(Mono<AsyncIndexTask> asyncIndexTaskMono, InfoPolicy infoPolicy){
 		 return asyncIndexTaskMono.flatMapMany(indexTask ->
 				Flux.fromArray(aerospikeClient.getNodes())
+						.filter(Node::isActive)
 						.flatMap(node -> queryIndexStatus(infoPolicy, indexTask, node)
 								.delayElement(Duration.ofMillis(1000))
 								.repeat()