Fix.

infiniflow · Nov 15, 2024 · 5afef29 · 5afef29
1 parent 6e2b167
commit 5afef29
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 13 deletions.
diff --git a/python/restart_test/test_memidx.py b/python/restart_test/test_memidx.py
@@ -330,17 +330,17 @@ def part1(infinity_obj):
                 ]
             )
             # dump by line submit here
-            table_obj.insert(
-                [
-                    {
-                        "c1": 8192 + i,
-                        "c2": 8192 + i,
-                        "c3": SparseVector(indices=[1], values=[1.0]),
-                    }
-                    for i in range(100)
-                ]
-            )
             infinity_obj.flush_delta()
+            for i in range(100):
+                table_obj.insert(
+                    [
+                        {
+                            "c1": 8192 + i,
+                            "c2": 8192 + i,
+                            "c3": SparseVector(indices=[1], values=[1.0]),
+                        }
+                    ]
+                )
             # wait for dump by line done
             # time.sleep(4)
 
@@ -349,7 +349,7 @@ def part1(infinity_obj):
         delta_paths = list(pathlib.Path(catalog_dir).rglob("*DELTA*"))
         if len(delta_paths) < 1:
             print("Warning: delta checkpoint not triggered. skip this test")
-            # infinity_runner.clear()
+            infinity_runner.clear()
             return
 
         @decorator2
@@ -370,4 +370,4 @@ def part2(infinity_obj):
 
         part2()
 
-        # infinity_runner.clear()
+        infinity_runner.clear()
diff --git a/src/admin/admin_executor.cpp b/src/admin/admin_executor.cpp
@@ -611,7 +611,7 @@ Vector<SharedPtr<WalEntry>> AdminExecutor::GetAllCheckpointEntries(QueryContext
         for (auto &entry_cmd : wal_entry_ptr->cmds_) {
             if (entry_cmd->GetType() == WalCommandType::CHECKPOINT) {
                 WalCmdCheckpoint *checkpoint_cmd = static_cast<WalCmdCheckpoint *>(entry_cmd.get());
-                max_checkpoint_ts = checkpoint_cmd->max_commit_ts_;
+                max_checkpoint_ts = std::max(max_checkpoint_ts, TxnTimeStamp(checkpoint_cmd->max_commit_ts_));
             }
         }
     }