bzhaoopenstack opened a new pull request, #20751:
URL: https://github.com/apache/flink/pull/20751
This patch adds a validation when user setting the FLINK_HOME env.
If the flink version from FLINK_HOME is the same as the pyflink, we
trust the FLINK_HOME, otherwise will rewrite the FLINK_HOME env anyway.
## What is the purpose of the change
improve the user experience and left a suggestion before exit.
## Brief change log
- Add a func for comparing the pyflink version and flink version from
FLINK_HOME env
- Don't trust FLINK_HOME if the system env had been setting before
validation
- Even FLINK_HOME env had been setted before running pyflink job. Once the
validation is failure, the logic will overwrite the FLINK_HOME.
## Verifying this change
Exec a pyflink job, and try to make sure the pyflink version and the flink
version of FLINK_HOME are different.
## 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]
