From 1529c08c15b7ac222eee0de7bb64bf6a33a26598 Mon Sep 17 00:00:00 2001
From: Au_Miner <358671982@qq.com>
Date: Thu, 11 Jun 2026 10:02:22 +0800
Subject: [PATCH] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest
 by adding padding records to prevent mini-batch merging

---
 .../plan/nodes/exec/stream/ChangelogNormalizeTestPrograms.java   | 1 +
 1 file changed, 1 insertion(+)

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")
     };