diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogNormalizeTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogNormalizeTestPrograms.java
index 786b4f57bb0a4..3f54e6e20319a 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogNormalizeTestPrograms.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogNormalizeTestPrograms.java
@@ -54,6 +54,7 @@ public class ChangelogNormalizeTestPrograms {
         Row.ofKind(RowKind.UPDATE_BEFORE, "four", 4, "d"),
         Row.ofKind(RowKind.UPDATE_AFTER, "four", 4, "dd"),
         Row.ofKind(RowKind.INSERT, "six", 6, "f"),
+        Row.ofKind(RowKind.DELETE, "seven", 7, "g"),
         Row.ofKind(RowKind.DELETE, "six", 6, "f")
     };