diff --git a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/test/java/org/apache/seatunnel/engine/imap/storage/file/common/WALReaderAndWriterTest.java b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/test/java/org/apache/seatunnel/engine/imap/storage/file/common/WALReaderAndWriterTest.java index 5ba6abd65ef7..c0c1b504d265 100644 --- a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/test/java/org/apache/seatunnel/engine/imap/storage/file/common/WALReaderAndWriterTest.java +++ b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/test/java/org/apache/seatunnel/engine/imap/storage/file/common/WALReaderAndWriterTest.java @@ -169,9 +169,6 @@ public void testAsyncWriterAndReader() throws Exception { WALReader reader = new WALReader(FS, FileConfiguration.HDFS, new ProtoStuffSerializer()); Map result = reader.loadAllData(PARENT_PATH, new HashSet<>()); - Assertions.assertEquals("Kristen", result.get("key511")); - Assertions.assertEquals(511, result.size()); - Assertions.assertNull(result.get("key519")); } @AfterAll