You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ti...@apache.org on 2021/05/14 02:04:45 UTC
[rocketmq] branch develop updated: Change log level to debug: "Half
offset {} has been committed/rolled back"
This is an automated email from the ASF dual-hosted git repository.
tigerlee pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 541c35d Change log level to debug: "Half offset {} has been committed/rolled back"
new be6eaf8 Merge pull request #2884 from areyouok/dev_speed_A
541c35d is described below
commit 541c35d054cd31064abe82b604fcb8b75a3a06fc
Author: huangli <ar...@gmail.com>
AuthorDate: Tue Jan 5 20:52:36 2021 +0800
Change log level to debug: "Half offset {} has been committed/rolled back"
---
.../broker/transaction/queue/TransactionalMessageServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java
index 1f5e01e..74df47a 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java
@@ -164,7 +164,7 @@ public class TransactionalMessageServiceImpl implements TransactionalMessageServ
break;
}
if (removeMap.containsKey(i)) {
- log.info("Half offset {} has been committed/rolled back", i);
+ log.debug("Half offset {} has been committed/rolled back", i);
Long removedOpOffset = removeMap.remove(i);
doneOpOffset.add(removedOpOffset);
} else {