wanglijie95 opened a new pull request #18023:
URL: https://github.com/apache/flink/pull/18023
## What is the purpose of the change
Allow to create execution vertices and execution edges lazily, for adaptive
batch scheduler.
## Brief change log
9949bf248f7e8bd90fcc3cac90b87ebe153761af Enable to create a dynamic graph.
4ecbaa4cb880d8b3af701788e061e9d8a0a72302 Allow ExecutionJobVertex to be
initialized lazily.
0268004b11d420c07814834ebe4798dfdf7ea5d7 Allow parallelism of
ExecutionJobVertex to be decided lazily.
## Verifying this change
Add some unit tests in `ExecutionJobVertexTest`,
`DefaultExecutionGraphConstructionTest`
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (**no**)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (**no**)
- The serializers: (**no**)
- The runtime per-record code paths (performance sensitive): (**no**)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (**no**)
- The S3 file system connector: (**no**)
## Documentation
- Does this pull request introduce a new feature? (**no**)
- If yes, how is the feature documented? (**not applicable**)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
