[TIMECHODB] Stabilize queue replacement race test

Author: Caideyipi

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeRealtimePriorityBlockingQueueTest.java

@@ -129,10 +129,10 @@ public void testPollCanRaceWithReplacementWithoutCorruptingQueue() throws Except
                       Collections.emptyList()));
       Assert.assertTrue(sourcePathRead.await(5, TimeUnit.SECONDS));
       final Future<Event> pollFuture = executor.submit(queue::directPoll);
+      Assert.assertSame(event, pollFuture.get(5, TimeUnit.SECONDS));
 
       allowReplacementToContinue.countDown();
       replacementFuture.get(5, TimeUnit.SECONDS);
-      Assert.assertSame(event, pollFuture.get(5, TimeUnit.SECONDS));
       verify(event, never())
           .decreaseReferenceCount(PipeRealtimePriorityBlockingQueue.class.getName(), false);
     } finally {