[rocketmq] branch 4.9.x updated: [ISSUE] Fix order consumer's lock issue when first start (#5466)

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch 4.9.x
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/4.9.x by this push:
     new eeecef350 [ISSUE] Fix order consumer's lock issue when first start 
(#5466)
eeecef350 is described below

commit eeecef3506d5b8190dcf912059524436ad625d8d
Author: Zhouxiang Zhan <zhouxiang....@alibaba-inc.com>
AuthorDate: Fri Nov 4 20:00:21 2022 +0800

    [ISSUE] Fix order consumer's lock issue when first start (#5466)
---
 .../java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
index f239d7946..7acc25cc8 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
@@ -374,6 +374,7 @@ public abstract class RebalanceImpl {
 
                 this.removeDirtyOffset(mq);
                 ProcessQueue pq = new ProcessQueue();
+                pq.setLocked(true);
 
                 long nextOffset = -1L;
                 try {