fix test

Author: 1782935682

test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java

@@ -90,14 +90,17 @@ public void testFilterPullConsumer() throws Exception {
         DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(group);
         consumer.setNamesrvAddr(NAMESRV_ADDR);
         consumer.start();
-        Thread.sleep(3000);
+        Set<MessageQueue> mqs = consumer.fetchSubscribeMessageQueues(topic);
+        consumer.getDefaultMQPullConsumerImpl()
+            .getRebalanceImpl()
+            .getmQClientFactory()
+            .sendHeartbeatToAllBrokerWithLock();
         producer.send("TagA", msgSize);
         producer.send("TagB", msgSize);
         producer.send("TagC", msgSize);
         Assert.assertEquals("Not all sent succeeded", msgSize * 3, producer.getAllUndupMsgBody().size());
 
         List<String> receivedMessage = new ArrayList<>(2);
-        Set<MessageQueue> mqs = consumer.fetchSubscribeMessageQueues(topic);
         for (MessageQueue mq : mqs) {
             SINGLE_MQ:
             while (true) {