diff --git a/test/cluster/test_logstor.py b/test/cluster/test_logstor.py
index 1dba454999..8731313749 100644
--- a/test/cluster/test_logstor.py
+++ b/test/cluster/test_logstor.py
@@ -86,6 +86,13 @@ async def test_basic_write_and_read(manager: ManagerClient):
         assert rows[0].pk == 2
         assert rows[0].v == 150
 
+        await cql.run_async(f"DELETE FROM {ks}.test_int WHERE pk = 1")
+        rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_int WHERE pk = 1")
+        assert len(rows) == 0
+        rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_int WHERE pk = 2")
+        assert rows[0].pk == 2
+        assert rows[0].v == 150
+
         # test conflict resolution by timestamp
         await cql.run_async(f"INSERT INTO {ks}.test_int (pk, v) VALUES (3, 300) USING TIMESTAMP 1000")
         await cql.run_async(f"INSERT INTO {ks}.test_int (pk, v) VALUES (3, 200) USING TIMESTAMP 900")
@@ -107,6 +114,10 @@ async def test_basic_write_and_read(manager: ManagerClient):
         assert rows[0].pk == 1
         assert rows[0].v == {'a': 'apple', 'b': 'banana', 'c': 'cherry'}
 
+        await cql.run_async(f"DELETE FROM {ks}.test_map WHERE pk = 1")
+        rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_map WHERE pk = 1")
+        assert len(rows) == 0
+
 @pytest.mark.asyncio
 async def test_range_read(manager: ManagerClient):
     cmdline = ['--logger-log-level', 'logstor=debug']