diff --git a/tsl/src/compression/compression_dml.c b/tsl/src/compression/compression_dml.c index 5026f97f9fa..0dad0c71c67 100644 --- a/tsl/src/compression/compression_dml.c +++ b/tsl/src/compression/compression_dml.c @@ -666,7 +666,7 @@ batch_matches(RowDecompressor *decompressor, ScanKeyData *scankeys, int num_scan )); } - if (constraints->on_conflict == ONCONFLICT_NOTHING) + if (constraints->on_conflict == ONCONFLICT_NOTHING && skip_current_tuple) { *skip_current_tuple = true; }