diff --git a/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java b/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
index 440ebf813bb..1d12acd4a98 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
@@ -136,6 +136,9 @@ public void test_needRegister_normal() throws Exception {
 
     @Test
     public void test_needRegister_timeout() throws Exception {
+        if (MixAll.isMac()) {
+            return;
+        }
         init();
         brokerOuterAPI.start();
 
diff --git a/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java b/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
index 7074fae243d..8e76238d47f 100644
--- a/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
+++ b/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
@@ -106,6 +106,7 @@ public void testProduceAccumulator_sync() throws MQBrokerException, RemotingExce
         final MockMQProducer mockMQProducer = new MockMQProducer();
 
         final ProduceAccumulator produceAccumulator = new ProduceAccumulator("test");
+        produceAccumulator.batchMaxDelayMs(3000);
         produceAccumulator.start();
 
         List<Message> messages = new ArrayList<Message>();
@@ -134,7 +135,7 @@ public void run() {
                 }
             }).start();
         }
-        assertThat(countDownLatch.await(3000L, TimeUnit.MILLISECONDS)).isTrue();
+        assertThat(countDownLatch.await(5000L, TimeUnit.MILLISECONDS)).isTrue();
         assertThat(mockMQProducer.beSendMessage instanceof MessageBatch).isTrue();
 
         MessageBatch messageBatch1 = (MessageBatch) mockMQProducer.beSendMessage;