Test: recover test case.

infiniflow · May 7, 2024 · ce4f267 · ce4f267
1 parent 860f64e
commit ce4f267
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 8 deletions.
diff --git a/python/parallel_test/test_chaos.py b/python/parallel_test/test_chaos.py
@@ -22,8 +22,6 @@
 
 class TestIndexParallel:
 
-    @pytest.mark.skip(
-        reason="Decrease row count exceed actual row count@src/storage/meta/entry/segment_entry.cppm:184, and update vector fail due to 'Not support to convert Embedding to Embedding'")
     def test_chaos(self, get_infinity_connection_pool):
         data = read_out_data()
         connection_pool = get_infinity_connection_pool

diff --git a/python/parallel_test/test_ddl_and_insert_delete.py b/python/parallel_test/test_ddl_and_insert_delete.py
@@ -17,8 +17,6 @@
 
 
 class TestInsertDeleteUpdate:
-    @pytest.mark.skip(
-        reason="#issue 1087 Decrease row count exceed actual row count@src/storage/meta/entry/segment_entry.cppm:184")
     def test_insert_delete_ddl_parallel(self, get_infinity_connection_pool):
         connection_pool = get_infinity_connection_pool
 

diff --git a/src/storage/wal/catalog_delta_entry.cpp b/src/storage/wal/catalog_delta_entry.cpp
@@ -1006,10 +1006,7 @@ void GlobalCatalogDeltaEntry::AddDeltaEntry(UniquePtr<CatalogDeltaEntry> delta_e
     } else {
         // Continuous
         do {
-            if (wal_size_ > wal_size) {
-                UnrecoverableError(fmt::format("wal_size_ {} > wal_size {}", wal_size_, wal_size));
-            }
-            wal_size_ = wal_size;
+            wal_size_ = std::max(wal_size_, wal_size);
             this->AddDeltaEntryInner(delta_entry.get());
 
             ++last_sequence_;