gaborgsomogyi commented on code in PR #26933:
URL: https://github.com/apache/flink/pull/26933#discussion_r2296680387
##########
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointMetadataTableFunction.java:
##########
@@ -41,6 +46,39 @@
+ "operator-coordinator-state-size-in-bytes
BIGINT NOT NULL, "
+ "operator-total-size-in-bytes BIGINT NOT
NULL>"))
public class SavepointMetadataTableFunction extends TableFunction<Row> {
+
+ public static final BuiltInFunctionDefinition SAVEPOINT_METADATA =
Review Comment:
Though it worth the discussion separate whether the planner caches it with
input params or not. I would guess yes, otherwise it just doesn't make sense
from usage point of view. If the params are stored together with the result
then adding `notDeterministic()` doesn't hurt but also not helping.
--
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]
