fix bug

a13519 · Aug 25, 2024 · 5404008 · 5404008
1 parent b90dbd1
commit 5404008
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/net/zousys/compressedtable/impl/singlekey/SingleKeyCompressedComparator.java b/src/main/java/net/zousys/compressedtable/impl/singlekey/SingleKeyCompressedComparator.java
@@ -131,6 +131,9 @@ public SingleKeyCompressedComparator compare() {
                         mml.add(key);
                         addMarker(mismatch);
                         comparatorListener.handleMisMatched(mismatch);
+                        // remove from before and after
+                        after.removeRowByMainKey(key);
+                        before.removeRowByMainKey(key);
                     } else {
                         // this is still matched if no fields are mismatch
                         // this could be the trimming or the strictColumn indicator is false
@@ -141,9 +144,6 @@ public SingleKeyCompressedComparator compare() {
 //                        after.removeRowByMainKey(key);
 //                        before.removeRowByMainKey(key);
                     }
-                    // remove from before and after
-                    after.removeRowByMainKey(key);
-                    before.removeRowByMainKey(key);
                 } catch (DataFormatException e) {
                     throw new RuntimeException(e);
                 } catch (IOException e) {