[
https://issues.apache.org/jira/browse/FLINK-32053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-32053:
------------------------------
Description:
This subtask should introduce StateMetadata to all ExecNodes that translate to
stateful operators, changing the way how `#translateToPlanInternal` get the
state retention time. The affected `ExecNode` list
{code:java}
StreamExecChangelogNormalize
StreamExecDeduplicate
StreamExecGlobalGroupAggregate
StreamExecGroupAggregate
StreamExecIncrementalGroupAggregate
StreamExecJoin
StreamExecLimit
StreamExecLookupJoin
StreamExecRank
StreamExecSink
StreamExecSortLimit
{code}
Since we have upgraded some `ExecNode`s to version 2, we have to test the
following 3 parts:
1. the plans serialized using version 1 can be deserialized using the current
version.
2. the plans with the current version SerDe work as expected.
3. The way by modifying the JSON content to change state TTL works as expected.
> Introduce StateMetadata to ExecNode to support configure operator-level state
> TTL via CompiledPlan
> --------------------------------------------------------------------------------------------------
>
> Key: FLINK-32053
> URL: https://issues.apache.org/jira/browse/FLINK-32053
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Affects Versions: 1.18.0
> Reporter: Jane Chan
> Priority: Major
> Fix For: 1.18.0
>
>
> This subtask should introduce StateMetadata to all ExecNodes that translate
> to stateful operators, changing the way how `#translateToPlanInternal` get
> the state retention time. The affected `ExecNode` list
> {code:java}
> StreamExecChangelogNormalize
> StreamExecDeduplicate
> StreamExecGlobalGroupAggregate
> StreamExecGroupAggregate
> StreamExecIncrementalGroupAggregate
> StreamExecJoin
> StreamExecLimit
> StreamExecLookupJoin
> StreamExecRank
> StreamExecSink
> StreamExecSortLimit
> {code}
> Since we have upgraded some `ExecNode`s to version 2, we have to test the
> following 3 parts:
> 1. the plans serialized using version 1 can be deserialized using the current
> version.
> 2. the plans with the current version SerDe work as expected.
> 3. The way by modifying the JSON content to change state TTL works as
> expected.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
