fix rescheduling case

Signed-off-by: Derek Riley <derek.riley@swirldslabs.com>

Author: derektriley

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/BlockNodeConnectionManager.java

@@ -794,6 +794,7 @@ public void run() {
                 logger.debug("{} Failed to establish connection to block node. Will schedule a retry.", connection);
                 blockStreamMetrics.recordConnectionCreateFailure();
                 reschedule();
+                selectNewBlockNodeForStreaming(false);
             }
         }
 

hedera-node/test-clients/src/main/java/com/hedera/services/bdd/suites/blocknode/BlockNodeSuite.java

@@ -440,7 +440,7 @@ final Stream<DynamicTest> node0StreamingBlockNodeConnectionDropsTrickle() {
                                 "/localhost:%s/CLOSED] Connection state transitioned from CLOSING to CLOSED.",
                                 portNumbers.get(3)))),
                 doingContextual(spec -> connectionDropTime.set(Instant.now())),
-                blockNode(3).startImmediately(), // Pri 3
+                waitUntilNextBlocks(5),
                 blockNode(1).shutDownImmediately(), // Pri 1
                 sourcingContextual(spec -> assertBlockNodeCommsLogContainsTimeframe(
                         byNodeId(0),