You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/01/27 09:58:00 UTC
[jira] [Commented] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling
[ https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483020#comment-17483020 ]
Marios Trivyzas commented on FLINK-25387:
-----------------------------------------
It's addressed in the same PR as FLINK-25388 and FLINK-25389
> Introduce ExecNodeMetadata annotation and tooling
> -------------------------------------------------
>
> Key: FLINK-25387
> URL: https://issues.apache.org/jira/browse/FLINK-25387
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Timo Walther
> Assignee: Marios Trivyzas
> Priority: Major
> Labels: pull-request-available
>
> Introduce annotation:
> {code}
> @ExecNodeMetadata(
> // main information
> name = "stream-exec-sink",
> version = 1,
> // maintenance information for us/the community and our tests
> consumedOptions = {"table.exec.sink.not-null-enforcer", "table.exec.sink.upsert-materialize"}
> producedOperators = {"not-null-enforcer", "upsert-materializer"}
> minPlanVersion = FlinkVersion.1_15,
> minStateVersion = FlinkVersion.1_15)
> {code}
>
> * Introduce a util to map from name and version to concrete ExecNode class. This util is required to switch the JSON plan from `ReflectionUtil` class-based approach to annotation-based approach.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)