fix: 执行历史归档，备份冷数据不正确 #3349

TencentBlueKing · Dec 24, 2024 · db508c1 · db508c1
1 parent 173fd5d
commit db508c1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...main/java/com/tencent/bk/job/backup/archive/impl/AbstractJobInstanceSubTableArchiver.java b/...main/java/com/tencent/bk/job/backup/archive/impl/AbstractJobInstanceSubTableArchiver.java
@@ -68,9 +68,9 @@ public BackupResult backupRecords(List<Long> jobInstanceIds) {
         RecordResultSet<? extends TableRecord<?>> recordResultSet =
             jobInstanceHotRecordDAO.executeQuery(jobInstanceIds,
                 archiveTablePropsStorage.getReadRowLimit(tableName));
-        long readStartTime = System.currentTimeMillis();
         // 数据偏移量
         int offset = 0;
+        long readStartTime = System.currentTimeMillis();
         while (recordResultSet.next()) {
             List<? extends TableRecord<?>> records = recordResultSet.getRecords();
             long readEndTime = System.currentTimeMillis();
@@ -93,6 +93,8 @@ public BackupResult backupRecords(List<Long> jobInstanceIds) {
                     archiveTablePropsStorage.getBatchInsertRowSize(tableName));
                 backupRows += records.size();
             }
+
+            readStartTime = System.currentTimeMillis();
             offset += rowSize;
         }