This is an automated email from the ASF dual-hosted git repository.
jchan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new cb9e220c229 [FLINK-34271][table-planner] Fix unstable
GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
cb9e220c229 is described below
commit cb9e220c2291088459f0281aa8e8e8584436a9b2
Author: Xuyang <[email protected]>
AuthorDate: Wed Jan 31 21:32:43 2024 +0800
[FLINK-34271][table-planner] Fix unstable
GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
This closes #24226
---
.../exec/stream/GroupAggregateTestPrograms.java | 10 ++++++----
.../plan/agg-with-state-ttl-hint.json | 2 +-
.../agg-with-state-ttl-hint/savepoint/_metadata | Bin 11151 -> 11151 bytes
3 files changed, 7 insertions(+), 5 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateTestPrograms.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateTestPrograms.java
index 6c43cf90959..755eb781a35 100644
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateTestPrograms.java
+++
b/flink-table/flink-table-planner/src/test/java/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/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/plan/agg-with-state-ttl-hint.json
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/plan/agg-with-state-ttl-hint.json
index cebe1e5898b..cfdcfed459b 100644
---
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/plan/agg-with-state-ttl-hint.json
+++
b/flink-table/flink-table-planner/src/test/resources/restore-tests/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/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata
index 50e4bee3a94..e956dafb981 100644
Binary files
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata
and
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-group-aggregate_1/agg-with-state-ttl-hint/savepoint/_metadata
differ
