Skip to content

Commit 8496abe

Browse files
Test: recover test case.
1 parent 860f64e commit 8496abe

File tree

2 files changed

+1
-6
lines changed

2 files changed

+1
-6
lines changed

python/parallel_test/test_ddl_and_insert_delete.py

-2
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@
1717

1818

1919
class TestInsertDeleteUpdate:
20-
@pytest.mark.skip(
21-
reason="#issue 1087 Decrease row count exceed actual row count@src/storage/meta/entry/segment_entry.cppm:184")
2220
def test_insert_delete_ddl_parallel(self, get_infinity_connection_pool):
2321
connection_pool = get_infinity_connection_pool
2422

src/storage/wal/catalog_delta_entry.cpp

+1-4
Original file line numberDiff line numberDiff line change
@@ -1006,10 +1006,7 @@ void GlobalCatalogDeltaEntry::AddDeltaEntry(UniquePtr<CatalogDeltaEntry> delta_e
10061006
} else {
10071007
// Continuous
10081008
do {
1009-
if (wal_size_ > wal_size) {
1010-
UnrecoverableError(fmt::format("wal_size_ {} > wal_size {}", wal_size_, wal_size));
1011-
}
1012-
wal_size_ = wal_size;
1009+
wal_size_ = std::max(wal_size_, wal_size);
10131010
this->AddDeltaEntryInner(delta_entry.get());
10141011

10151012
++last_sequence_;

0 commit comments

Comments
 (0)