[FLINK-34271][table-planner] Fix unstable GroupAggregateRestoreTest#A…

…GG_WITH_STATE_TTL_HINT This closes #24226
apache · Jan 31, 2024 · cb9e220 · cb9e220
1 parent 5035808
commit cb9e220
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/...ava/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateTestPrograms.java b/...ava/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateTestPrograms.java
@@ -387,13 +387,15 @@ public class GroupAggregateTestPrograms {
                                             "+I[1, 1, null, Hi]",
                                             "+I[2, 1, 2.0, Hello]",
                                             "+U[2, 2, 2.0, Hello]")
+                                    // Due to state TTL in hint, the state in the metadata
+                                    // savepoint has expired.
                                     .consumedAfterRestore(
-                                            "+U[1, 2, null, Hi]",
-                                            "+U[2, 3, 2.0, Hello]",
-                                            "+U[2, 4, 2.0, Hello]")
+                                            "+I[1, 1, null, Hi Again!]",
+                                            "+I[2, 1, 2.0, Hello Again!]",
+                                            "+U[2, 2, 2.0, Hello Again!]")
                                     .build())
                     .runSql(
-                            "INSERT INTO sink_t SELECT /*+ STATE_TTL('source_t' = '4d') */"
+                            "INSERT INTO sink_t SELECT /*+ STATE_TTL('source_t' = '1s') */"
                                     + "b, "
                                     + "COUNT(*) AS cnt, "
                                     + "AVG(a) FILTER (WHERE a > 1) AS avg_a, "

diff --git a/...s/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/plan/agg-with-state-ttl-hint.json b/...s/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/plan/agg-with-state-ttl-hint.json
@@ -128,7 +128,7 @@
     "needRetraction" : false,
     "state" : [ {
       "index" : 0,
-      "ttl" : "4 d",
+      "ttl" : "1 s",
       "name" : "groupAggregateState"
     } ],
     "inputProperties" : [ {

diff --git a/...s/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata b/...s/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata