This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 55702a16fac [fix](binlog) Binlog ts not initialized (#47174)
55702a16fac is described below
commit 55702a16fac1031868869ee3acf7eadb3851564d
Author: Uniqueyou <wangyix...@selectdb.com>
AuthorDate: Tue Jan 21 22:35:22 2025 +0800
[fix](binlog) Binlog ts not initialized (#47174)
https://github.com/selectdb/ccr-syncer/pull/395
---
.../org/apache/doris/binlog/BinlogManager.java | 46 +++++++++++-----------
1 file changed, 23 insertions(+), 23 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java
b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java
index 69293ea6c00..848f408ce0b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java
@@ -184,7 +184,7 @@ public class BinlogManager {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(addPartitionRecord.getTableId());
long commitSeq = addPartitionRecord.getCommitSeq();
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ADD_PARTITION;
String data = addPartitionRecord.toJson();
@@ -196,7 +196,7 @@ public class BinlogManager {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(createTableRecord.getTableId());
long commitSeq = createTableRecord.getCommitSeq();
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.CREATE_TABLE;
String data = createTableRecord.toJson();
@@ -207,7 +207,7 @@ public class BinlogManager {
long dbId = dropPartitionInfo.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(dropPartitionInfo.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_PARTITION;
String data = dropPartitionInfo.toJson();
@@ -219,7 +219,7 @@ public class BinlogManager {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(record.getTableId());
long commitSeq = record.getCommitSeq();
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_TABLE;
String data = record.toJson();
@@ -230,7 +230,7 @@ public class BinlogManager {
long dbId = alterJob.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(alterJob.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ALTER_JOB;
AlterJobRecord alterJobRecord = new AlterJobRecord(alterJob);
String data = alterJobRecord.toJson();
@@ -242,7 +242,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_TABLE_ADD_OR_DROP_COLUMNS;
String data = info.toJson();
@@ -253,7 +253,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ALTER_DATABASE_PROPERTY;
String data = info.toJson();
@@ -264,7 +264,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_TABLE_PROPERTY;
String data = info.toJson();
@@ -285,7 +285,7 @@ public class BinlogManager {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(tableId);
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.BARRIER;
String data = barrierLog.toJson();
@@ -297,7 +297,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_PARTITIONS;
String data = info.toJson();
@@ -309,7 +309,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.REPLACE_PARTITIONS;
String data = info.toJson();
@@ -321,7 +321,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.TRUNCATE_TABLE;
TruncateTableRecord record = new TruncateTableRecord(info);
String data = record.toJson();
@@ -333,7 +333,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_TABLE;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false,
info);
@@ -343,7 +343,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_ROLLUP;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false,
info);
@@ -353,7 +353,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_PARTITION;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false,
info);
@@ -363,7 +363,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_COMMENT;
String data = info.toJson();
@@ -374,7 +374,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_COLUMN;
String data = info.toJson();
@@ -386,7 +386,7 @@ public class BinlogManager {
long dbId = alterViewInfo.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(alterViewInfo.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_VIEW_DEF;
String data = alterViewInfo.toJson();
@@ -402,7 +402,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getOrigTblId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.REPLACE_TABLE;
String data = info.toJson();
@@ -413,7 +413,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type =
TBinlogType.MODIFY_TABLE_ADD_OR_DROP_INVERTED_INDICES;
String data = info.toJson();
@@ -424,7 +424,7 @@ public class BinlogManager {
long dbId = indexChangeJob.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(indexChangeJob.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.INDEX_CHANGE_JOB;
String data = indexChangeJob.toJson();
@@ -440,7 +440,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_ROLLUP;
String data = info.toJson();
@@ -466,7 +466,7 @@ public class BinlogManager {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
- long timestamp = -1;
+ long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RECOVER_INFO;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false,
info);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
