This is an automated email from the ASF dual-hosted git repository.
snuyanzin 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 bf03f06b513 [hotfix][FLINK-39261][table] Regenerate `FROM_CHANGELOG`
restore test to fix build
bf03f06b513 is described below
commit bf03f06b5138bf0ce1fedfd6518119e5cedf683d
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Thu Apr 23 23:56:53 2026 +0200
[hotfix][FLINK-39261][table] Regenerate `FROM_CHANGELOG` restore test to
fix build
---
.../plan/from-changelog-retract-restore.json | 9 +++++++--
.../savepoint/_metadata | Bin 7310 -> 7222 bytes
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/plan/from-changelog-retract-restore.json
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/plan/from-changelog-retract-restore.json
index 8cdaa6e5449..b795986b6d6 100644
---
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/plan/from-changelog-retract-restore.json
+++
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/plan/from-changelog-retract-restore.json
@@ -35,7 +35,7 @@
"priority" : 0
} ],
"outputType" : "ROW<`id` INT, `name` VARCHAR(2147483647)>",
- "description" :
"ProcessTableFunction(invocation=[FROM_CHANGELOG(TABLE(#0), DEFAULT(),
DEFAULT(), DEFAULT(), DEFAULT())], uid=[null], select=[id,name],
rowType=[RecordType(INTEGER id, VARCHAR(2147483647) name)])",
+ "description" :
"ProcessTableFunction(invocation=[FROM_CHANGELOG(TABLE(#0), DEFAULT(),
DEFAULT(), DEFAULT(), DEFAULT(), DEFAULT())], uid=[null], select=[id,name],
rowType=[RecordType(INTEGER id, VARCHAR(2147483647) name)])",
"uid" : null,
"functionCall" : {
"kind" : "CALL",
@@ -57,6 +57,11 @@
"syntax" : "SPECIAL",
"internalName" : "$DEFAULT$1",
"type" : "MAP<VARCHAR(2147483647), VARCHAR(2147483647)>"
+ }, {
+ "kind" : "CALL",
+ "syntax" : "SPECIAL",
+ "internalName" : "$DEFAULT$1",
+ "type" : "VARCHAR(2147483647)"
}, {
"kind" : "CALL",
"syntax" : "SPECIAL",
@@ -99,7 +104,7 @@
}
},
"inputChangelogMode" : [ "INSERT", "UPDATE_BEFORE", "UPDATE_AFTER",
"DELETE" ],
- "upsertMaterializeStrategy" : "ADAPTIVE",
+ "upsertMaterializeStrategy" : "MAP",
"inputProperties" : [ {
"requiredDistribution" : {
"type" : "UNKNOWN"
diff --git
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/savepoint/_metadata
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/savepoint/_metadata
index ccf7b073b66..af7d53ef6c3 100644
Binary files
a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/savepoint/_metadata
and
b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-restore/savepoint/_metadata
differ