tests fixed

redisson/src/main/java/org/redisson/mapreduce/MapReduceExecutor.java

@@ -92,7 +92,7 @@ abstract class MapReduceExecutor<M, VIn, KOut, VOut> implements RMapReduceExecut
         RFuture<Void> future = executeMapperAsync(resultMapName, null);
         if (timeout > 0) {
             commandExecutor.getConnectionManager().newTimeout(task -> {
-                promise.cancel(true);
+                promise.tryFailure(new MapReduceTimeoutException());
             }, timeout, TimeUnit.MILLISECONDS);
         }
 

redisson/src/test/java/org/redisson/RedissonBlockingDequeTest.java

@@ -66,10 +66,10 @@ public class RedissonBlockingDequeTest extends BaseTest {
     @Test
     public void testPollLastAndOfferFirstTo() throws InterruptedException {
         RBlockingDeque<String> blockingDeque = redisson.getBlockingDeque("blocking_deque");
-        long start = System.currentTimeMillis();
-        String redisTask = blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS);
-        assertThat(System.currentTimeMillis() - start).isBetween(950L, 1100L);
-        assertThat(redisTask).isNull();
+        Awaitility.await().between(Duration.ofMillis(1000), Duration.ofMillis(1200)).untilAsserted(() -> {
+            String redisTask = blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS);
+            assertThat(redisTask).isNull();
+        });
     }
     
     @Test

redisson/src/test/java/org/redisson/RedissonPriorityQueueTest.java

@@ -95,7 +95,12 @@ public class RedissonPriorityQueueTest extends BaseTest {
         list.add("5");
         list.add("3");
 
-        list.removeIf(value -> value.equals("2"));
+        for (Iterator<String> iterator = list.iterator(); iterator.hasNext();) {
+            String value = iterator.next();
+            if (value.equals("2")) {
+                iterator.remove();
+            }
+        }
 
         assertThat(list).contains("1", "4", "5", "3");