Skip to content

Commit 59033a3

Browse files
authored
[ISSUE #10199] Fix stale write timestamp leads to duplicate transaction commit (#10200)
1 parent 8d451f3 commit 59033a3

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -710,6 +710,7 @@ public long batchSendOpMessage() {
710710
// wait for the interval
711711
mqContext.getTotalSize().get() < maxSize &&
712712
startTime - mqContext.getLastWriteTimestamp() < interval) {
713+
firstTimestamp = Math.min(firstTimestamp, mqContext.getLastWriteTimestamp());
713714
continue;
714715
}
715716

0 commit comments

Comments
 (0)