This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new c0813750722 branch-3.0: [fix](binlog) Set dummy timestamp correctly
#48706 (#48754)
c0813750722 is described below
commit c0813750722f5cef3a97aff06536a756320b2b92
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Mar 10 20:46:51 2025 +0800
branch-3.0: [fix](binlog) Set dummy timestamp correctly #48706 (#48754)
Cherry-picked from #48706
Co-authored-by: walter <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java | 3 ++-
fe/fe-core/src/main/java/org/apache/doris/binlog/DBBinlog.java | 1 +
fe/fe-core/src/main/java/org/apache/doris/binlog/TableBinlog.java | 1 +
3 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java
b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java
index 1fa930cd4d7..66350cec0d3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java
@@ -68,7 +68,7 @@ public class BinlogUtils {
if (firstBinlog.getCommitSeq() > prevCommitSeq) {
BinlogLagInfo lagInfo = new BinlogLagInfo(binlogs.size(),
firstBinlog.getCommitSeq(),
- firstBinlog.getTimestamp(), lastBinlog.getCommitSeq(),
lastBinlog.getTimestamp());
+ lastBinlog.getCommitSeq(), firstBinlog.getTimestamp(),
lastBinlog.getTimestamp());
return Pair.of(status, lagInfo);
}
@@ -101,6 +101,7 @@ public class BinlogUtils {
dummy.setType(TBinlogType.DUMMY);
dummy.setDbId(dbId);
dummy.setBelong(tableId);
+ dummy.setTimestamp(System.currentTimeMillis());
return dummy;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/DBBinlog.java
b/fe/fe-core/src/main/java/org/apache/doris/binlog/DBBinlog.java
index bd7fd184426..8e2c7bbde96 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/binlog/DBBinlog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/DBBinlog.java
@@ -459,6 +459,7 @@ public class DBBinlog {
if (lastExpiredBinlog != null) {
final long expiredCommitSeq = lastExpiredBinlog.getCommitSeq();
dummy.setCommitSeq(expiredCommitSeq);
+ dummy.setTimestamp(lastExpiredBinlog.getTimestamp());
// release expired timestamps by commit seq.
Iterator<Pair<Long, Long>> timeIter = timestamps.iterator();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/TableBinlog.java
b/fe/fe-core/src/main/java/org/apache/doris/binlog/TableBinlog.java
index cef60c85ac4..8eb27de8092 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/binlog/TableBinlog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/TableBinlog.java
@@ -211,6 +211,7 @@ public class TableBinlog {
final long expiredCommitSeq = lastExpiredBinlog.getCommitSeq();
dummyBinlog.setCommitSeq(expiredCommitSeq);
+ dummyBinlog.setTimestamp(lastExpiredBinlog.getTimestamp());
Iterator<Pair<Long, Long>> timeIterator = timestamps.iterator();
while (timeIterator.hasNext() && timeIterator.next().first <=
expiredCommitSeq) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
