SteNicholas opened a new pull request #15020:
URL: https://github.com/apache/flink/pull/15020
## What is the purpose of the change
*Application mode uses `ClassPathPackagedProgramRetriever` to create the
`PackagedProgram` which doesn't set the configuration. This causes some client
configurations not take effect. `ClassPathPackagedProgramRetriever` should
refactor to have separate classes for the Python-based PackagedProgram and the
PackagedProgram with and without a jar.*
## Brief change log
- *`ClassPathPackagedProgramRetriever` refactors to have separate
implementations which are `PythonBasedPackagedProgramRetriever`,
`JarFilePackagedProgramRetriever` and `ScanClassPathPackagedProgramRetriever`,
which set the configuration to `PackagedProgram`.*
- *`ApplicationClusterEntryPoint` gets the `PackagedProgramRetriever` with
setting the configuration.*
## Verifying this change
- *`ClassPathPackagedProgramRetrieverTest` adds the test case
`testGetPackagedProgramWithConfiguration` to verify whether get the
`PackagedProgram` with the specified configuration.*
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes / **no**)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes / **no**)
- The serializers: (yes / **no** / don't know)
- The runtime per-record code paths (performance sensitive): (yes / **no**
/ don't know)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: (yes / **no** /
don't know)
- The S3 file system connector: (yes / **no** / don't know)
## Documentation
- Does this pull request introduce a new feature? (yes / **no**)
- If yes, how is the feature documented? (**not applicable** / docs /
JavaDocs / not documented)
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
