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

Reply via email to