Details
-
Sub-task
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.19.0
Description
This issue aims to verify FLIP-379.
New Source can implement the interface DynamicParallelismInference to enable dynamic parallelism inference. For detailed information, please refer to the documentation.
We may need to cover the following two types of test cases:
Test 1: FileSource has implemented the dynamic source parallelism inference. Test the automatic parallelism inference of FileSource.
Test 2: Test the dynamic source parallelism inference of a custom Source.
Attachments
Issue Links
- is a clone of
-
FLINK-34287 Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs
- Closed
- relates to
-
FLINK-33768 FLIP-379: Support dynamic source parallelism inference for batch jobs
- Closed