You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/11/04 12:00:37 UTC
[rocketmq] branch 4.9.x updated: [ISSUE] Fix order consumer's lock issue when first start (#5466)
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 <zh...@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 {