[FLINK-33421] Implement ExecNode Restore Tests

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / Planner
• Assignee: Bonnie Varghese
• Reporter: Bonnie Varghese
• Created: 31/Oct/23 21:44
• Updated: 08/Apr/24 14:03

Description

Implement Restore Tests for various exec nodes to improve coverage

Related JIRA: https://issues.apache.org/jira/browse/FLINK-33375

Issue Links

• causes: FLINK-34513 GroupAggregateRestoreTest.testRestore fails
• causes: FLINK-35012 ChangelogNormalizeRestoreTest.testRestore failure
• incorporates: FLINK-34268 Add a test to verify if restore test exists for ExecNode
• is part of: FLINK-33375 Add a RestoreTestBase
• is part of: FLINK-25809 Introduce test infra for building FLIP-190 tests
• is part of: FLINK-25217 FLIP-190: Support Version Upgrades for Table API & SQL Programs

Sub-Tasks

• Implement restore tests for PythonCalc node: Open
• Implement restore tests for PythonCorrelate node: Open
• Implement restore tests for PythonGroupAggregate node: Open
• Implement restore tests for PythonGroupWindowAggregate node: Open