dawidwys commented on code in PR #27301:
URL: https://github.com/apache/flink/pull/27301#discussion_r2613459496
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSink.java:
##########
@@ -65,6 +65,25 @@
},
minPlanVersion = FlinkVersion.v2_0,
minStateVersion = FlinkVersion.v2_0)
+// Version 2: Fixed the data type used for creating constraint enforcer and
sink upsert
+// materializer. Since this version the sink works correctly with persisted
metadata columns.
+// We introduced a new version, because statements that were never rolling
back to a value from
+// state could run succesfully. We allow those jobs to be upgraded. Without a
new versions such jobs
+// would fail on restore, because the state serializer would differ
+@ExecNodeMetadata(
Review Comment:
Good point. Overlooked that in your commit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
