Skip to content

Commit bf03f06

Browse files
authored
[hotfix][FLINK-39261][table] Regenerate FROM_CHANGELOG restore test to fix build
1 parent 76e194a commit bf03f06

2 files changed

Lines changed: 7 additions & 2 deletions

File tree

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
"priority" : 0
3636
} ],
3737
"outputType" : "ROW<`id` INT, `name` VARCHAR(2147483647)>",
38-
"description" : "ProcessTableFunction(invocation=[FROM_CHANGELOG(TABLE(#0), DEFAULT(), DEFAULT(), DEFAULT(), DEFAULT())], uid=[null], select=[id,name], rowType=[RecordType(INTEGER id, VARCHAR(2147483647) name)])",
38+
"description" : "ProcessTableFunction(invocation=[FROM_CHANGELOG(TABLE(#0), DEFAULT(), DEFAULT(), DEFAULT(), DEFAULT(), DEFAULT())], uid=[null], select=[id,name], rowType=[RecordType(INTEGER id, VARCHAR(2147483647) name)])",
3939
"uid" : null,
4040
"functionCall" : {
4141
"kind" : "CALL",
@@ -57,6 +57,11 @@
5757
"syntax" : "SPECIAL",
5858
"internalName" : "$DEFAULT$1",
5959
"type" : "MAP<VARCHAR(2147483647), VARCHAR(2147483647)>"
60+
}, {
61+
"kind" : "CALL",
62+
"syntax" : "SPECIAL",
63+
"internalName" : "$DEFAULT$1",
64+
"type" : "VARCHAR(2147483647)"
6065
}, {
6166
"kind" : "CALL",
6267
"syntax" : "SPECIAL",
@@ -99,7 +104,7 @@
99104
}
100105
},
101106
"inputChangelogMode" : [ "INSERT", "UPDATE_BEFORE", "UPDATE_AFTER", "DELETE" ],
102-
"upsertMaterializeStrategy" : "ADAPTIVE",
107+
"upsertMaterializeStrategy" : "MAP",
103108
"inputProperties" : [ {
104109
"requiredDistribution" : {
105110
"type" : "UNKNOWN"

0 commit comments

Comments
 (0)