diff --git a/tests/integration/test_storage_iceberg_with_spark/configs/config.d/cluster.xml b/tests/integration/test_storage_iceberg_with_spark/configs/config.d/cluster.xml
index 54c08b27abe8..5835f155a998 100644
--- a/tests/integration/test_storage_iceberg_with_spark/configs/config.d/cluster.xml
+++ b/tests/integration/test_storage_iceberg_with_spark/configs/config.d/cluster.xml
@@ -16,5 +16,17 @@
                 </replica>
             </shard>
         </cluster_simple>
+        <cluster_23>
+            <shard>
+                <replica>
+                    <host>node2</host>
+                    <port>9000</port>
+                </replica>
+                <replica>
+                    <host>node3</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+        </cluster_23>
     </remote_servers>
 </clickhouse>
diff --git a/tests/integration/test_storage_iceberg_with_spark/test_remote_initiator.py b/tests/integration/test_storage_iceberg_with_spark/test_remote_initiator.py
index a5b833c8a2ea..763836d21f60 100644
--- a/tests/integration/test_storage_iceberg_with_spark/test_remote_initiator.py
+++ b/tests/integration/test_storage_iceberg_with_spark/test_remote_initiator.py
@@ -54,7 +54,7 @@ def flush_logs():
             FROM {TABLE_NAME}
             WHERE number=1
         SETTINGS
-            object_storage_cluster='cluster_simple'
+            object_storage_cluster='cluster_23'
         """,
         query_id = query_id)
     assert res == "1\t1\n"
@@ -64,8 +64,8 @@ def flush_logs():
             FROM clusterAllReplicas('cluster_simple', system.query_log)
             WHERE type='QueryFinish' AND initial_query_id='{query_id}'
         """)
-    # initial node + 3 subqueries on replicas
-    assert queries == "4\n"
+    # initial node + 2 subqueries on replicas
+    assert queries == "3\n"
 
     query_id = uuid.uuid4().hex
     res = instance.query(f"""
@@ -74,7 +74,7 @@ def flush_logs():
             WHERE number=1
         SETTINGS
             object_storage_remote_initiator=1,
-            object_storage_cluster='cluster_simple'
+            object_storage_cluster='cluster_23'
         """,
         query_id = query_id)
     assert res == "1\t1\n"
@@ -84,8 +84,8 @@ def flush_logs():
             FROM clusterAllReplicas('cluster_simple', system.query_log)
             WHERE type='QueryFinish' AND initial_query_id='{query_id}'
         """)
-    # initial node + remote initiator + 3 subqueries on replicas
-    assert queries == "5\n"
+    # initial node + remote initiator + 2 subqueries on replicas
+    assert queries == "4\n"
 
     query_id = uuid.uuid4().hex
     res = instance.query(f"""