-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Flink upgrade 1.16.2 and compatible with multiple versions #4753
Flink upgrade 1.16.2 and compatible with multiple versions #4753
Conversation
Good job |
Multi-version compatibility needs to be considered |
Ok, thanks for reviewing the code |
cc @Alexkun |
# Conflicts: # linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.java # linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/context/EnvironmentContext.scala # linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
# Conflicts: # tool/dependencies/known-dependencies.txt
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
支持的多版本包括1.13.x版本吗 Does the multiple versions supported include 1.13.x |
Sorry, 1.13 is not currently supported |
* Flink upgrade 1.16.2 * Flink is compatible with multiple versions * Compatible with flink1.16.2 modifications * Compatible with flink1.12.2 modifications * Compatible with flink1.12.2 modifications * Modify the flink version * Compatible with flink1.12.2 modifications * Remove useless code * Modified flink-shims-1.16.2 pom * Modified known-dependencies.txt * add license * Resolving code conflicts * Resolving code conflicts * Resolving code conflicts * Resolving code conflicts * Resolving code conflicts * spark support yarn cluster * Modify flink pom (cherry picked from commit f08773d) Signed-off-by: alexkun <[email protected]>
Flink upgrade 1.16.2
"flink.version" defaults to "1.16.2 ". If you want to use flink1.12.2, you need to set "flink.version" to "1.12.2 "and recompile the source code