Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.18.0
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
StreamExecChangelogNormalize StreamExecDeduplicate StreamExecGlobalGroupAggregate StreamExecGroupAggregate StreamExecIncrementalGroupAggregate StreamExecJoin StreamExecLimit StreamExecLookupJoin StreamExecRank StreamExecSink StreamExecSortLimit
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.