From c31274522fb82d356d29cc63527cb96065b876e9 Mon Sep 17 00:00:00 2001 From: wyxxxcat Date: Fri, 17 Jan 2025 18:01:16 +0800 Subject: [PATCH] 1 --- .../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 9028acee2f0470..f560297861db84 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 void addAddPartitionRecord(AddPartitionRecord addPartitionRecord) { List 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 void addCreateTableRecord(CreateTableRecord createTableRecord) { List 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 void addDropPartitionRecord(DropPartitionInfo dropPartitionInfo, long com long dbId = dropPartitionInfo.getDbId(); List 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 void addDropTableRecord(DropTableRecord record) { List 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 void addAlterJobV2(AlterJobV2 alterJob, long commitSeq) { long dbId = alterJob.getDbId(); List 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 void addModifyTableAddOrDropColumns(TableAddOrDropColumnsInfo info, long long dbId = info.getDbId(); List 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 void addAlterDatabaseProperty(AlterDatabasePropertyInfo info, long commit long dbId = info.getDbId(); List 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 void addModifyTableProperty(ModifyTablePropertyOperationLog info, long co long dbId = info.getDbId(); List 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 void addBarrierLog(BarrierLog barrierLog, long commitSeq) { List 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 void addModifyPartitions(BatchModifyPartitionsInfo info, long commitSeq) long dbId = info.getDbId(); List 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 void addReplacePartitions(ReplacePartitionOperationLog info, long commitS long dbId = info.getDbId(); List 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 void addTruncateTable(TruncateTableInfo info, long commitSeq) { long dbId = info.getDbId(); List 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 void addTableRename(TableInfo info, long commitSeq) { long dbId = info.getDbId(); List 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 void addRollupRename(TableInfo info, long commitSeq) { long dbId = info.getDbId(); List 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 void addPartitionRename(TableInfo info, long commitSeq) { long dbId = info.getDbId(); List 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 void addModifyComment(ModifyCommentOperationLog info, long commitSeq) { long dbId = info.getDbId(); List 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 void addColumnRename(TableRenameColumnInfo info, long commitSeq) { long dbId = info.getDbId(); List 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 void addModifyViewDef(AlterViewInfo alterViewInfo, long commitSeq) { long dbId = alterViewInfo.getDbId(); List 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 void addReplaceTable(ReplaceTableOperationLog info, long commitSeq) { long dbId = info.getDbId(); List 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 void addModifyTableAddOrDropInvertedIndices(TableAddOrDropInvertedIndices long dbId = info.getDbId(); List 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 void addIndexChangeJob(IndexChangeJob indexChangeJob, long commitSeq) { long dbId = indexChangeJob.getDbId(); List 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 void addDropRollup(DropInfo info, long commitSeq) { long dbId = info.getDbId(); List tableIds = Lists.newArrayList(); tableIds.add(info.getTableId()); - long timestamp = -1; + long timestamp = System.currentTimeMillis(); TBinlogType type = TBinlogType.DROP_ROLLUP; String data = info.toJson(); @@ -467,7 +467,7 @@ public void addRecoverTableRecord(RecoverInfo info, long commitSeq) { long dbId = info.getDbId(); List 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);