You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampark.apache.org by "cygnusdark (via GitHub)" <gi...@apache.org> on 2023/05/05 03:06:27 UTC
[GitHub] [incubator-streampark] cygnusdark opened a new issue, #2723: [Bug] Bug title
cygnusdark opened a new issue, #2723:
URL: https://github.com/apache/incubator-streampark/issues/2723
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
### Java Version
1.8
### Scala Version
2.12.x
### StreamPark Version
2.1.0
### Flink Version
1.17.0
### deploy mode
yarn-application
### What happened
When I restart a job from previous save point, I got an error exception:
Then I checked that Flink shims 1.17 module does not include Flink Client dependency. Flink Client dependency is in Flink shims base, and Flink shims base dependencies is based on Flink 1.14.4. It looks like a compatibility problem.
I think there are two ways to fix this bug:
1. upgrade the Flink version to 1.17.0 in Flink shims base (looks impossible because we also need to support flink 1.14+)
2. manually replace the Flink Client version from 1.14.4 to 1.17.0 in Flink shims 1.17.0
Is there better way to fix this problem?
### Error Exception
```log
Caused by: java.lang.NoSuchMethodError: org.apache.commons.cli.CommandLine.hasOption(Lorg/apache/commons/cli/Option;)Z
at org.apache.flink.client.cli.CliFrontendParser.createSavepointRestoreSettings(CliFrontendParser.java:631)
at org.apache.flink.client.cli.ProgramOptions.<init>(ProgramOptions.java:119)
at org.apache.flink.client.cli.ProgramOptions.create(ProgramOptions.java:192)
at org.apache.streampark.flink.client.trait.FlinkClientTrait.submit(FlinkClientTrait.scala:87)
at org.apache.streampark.flink.client.trait.FlinkClientTrait.submit$(FlinkClientTrait.scala:63)
at org.apache.streampark.flink.client.impl.YarnApplicationClient$.submit(YarnApplicationClient.scala:44)
at org.apache.streampark.flink.client.FlinkClientHandler$.submit(FlinkClientHandler.scala:40)
at org.apache.streampark.flink.client.FlinkClientHandler.submit(FlinkClientHandler.scala)
```
### Screenshots
<img width="1581" alt="image" src="https://user-images.githubusercontent.com/53288632/236369661-f06cf84d-bc10-461a-bbbb-ae1db36ea429.png">
### Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!(您是否要贡献这个PR?)
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
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: issues-unsubscribe@streampark.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [incubator-streampark] wolfboys commented on issue #2723: [Bug] Compatibility problem under fink 1.17.0 version when restoring job from savepoint
Posted by "wolfboys (via GitHub)" <gi...@apache.org>.
wolfboys commented on issue #2723:
URL: https://github.com/apache/incubator-streampark/issues/2723#issuecomment-1539473454
Our developer has tested it and found no issues running it under Flink 1.17. You may want to check if there are any commons-cli related jars in your flink/lib directory.
--
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: issues-unsubscribe@streampark.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] Compatibility problem under fink 1.17.0 version when restoring job from savepoint [incubator-streampark]
Posted by "wolfboys (via GitHub)" <gi...@apache.org>.
wolfboys commented on issue #2723:
URL: https://github.com/apache/incubator-streampark/issues/2723#issuecomment-1844406521
Answered
--
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: issues-unsubscribe@streampark.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] Compatibility problem under fink 1.17.0 version when restoring job from savepoint [incubator-streampark]
Posted by "wolfboys (via GitHub)" <gi...@apache.org>.
wolfboys closed issue #2723: [Bug] Compatibility problem under fink 1.17.0 version when restoring job from savepoint
URL: https://github.com/apache/incubator-streampark/issues/2723
--
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: issues-unsubscribe@streampark.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org