Tks for your suggestion xuyang.
I have solved this problem by packing a new
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar with the conflict jar shaded.
________________________________
发件人: Xuyang <xyzhong...@163.com>
发送时间: 2022年9月1日 0:27
收件人: user@flink.apache.org <user@flink.apache.org>
抄送: luoyu...@alumni.sjtu.edu.cn <luoyu...@alumni.sjtu.edu.cn>; Liting Liu
(litiliu) <liti...@cisco.com>
主题: Re:Re: get NoSuchMethodError when using flink
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar
Hi, Liu.
It seems that you may use other own jars and thay has the common-lang3 with
other versions, which may cause the version conflict.
My suggesstion is that you can shade this dependency in your own jars or in
'flink-table-planner', and the latter may require you to compile flink manually.
--
Best！
Xuyang
在 2022-08-31 20:28:43，"yuxia" <luoyu...@alumni.sjtu.edu.cn> 写道：
How do you use `flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar`? Do you use sql
client ? Do you put it in FLINK_HOME/lib?
If it's for sql client, I think you can remove the jar from FLINK_HOME/lib,
but add it in Flink SQL client using `add jar
'flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar' `, and set
'org.apache.commons.' the to parent-first[1]
But I think the better way is to relocate the class.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#classloader-parent-first-patterns-default
Best regards,
Yuxia
________________________________
发件人: "Liting Liu (litiliu)" <liti...@cisco.com>
收件人: "User" <user@flink.apache.org>
发送时间: 星期三, 2022年 8 月 31日 下午 5:14:35
主题: get NoSuchMethodError when using flink
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar
Hi, i got NoSuchMethodError when using flink
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar.
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
Caused by: java.lang.NoSuchMethodError:
org.apache.commons.lang3.StringUtils.join([IC)Ljava/lang/String;
at
org.apache.flink.table.planner.plan.utils.RankProcessStrategy$UpdateFastStrategy.toString(RankProcessStrategy.java:129)
at java.lang.String.valueOf(String.java:2994)
at java.lang.StringBuilder.append(StringBuilder.java:136)
at
org.apache.flink.table.planner.plan.utils.RelDescriptionWriterImpl.explain(RelDescriptionWriterImpl.java:67)
at
org.apache.flink.table.planner.plan.utils.RelDescriptionWriterImpl.done(RelDescriptionWriterImpl.java:96)
at
org.apache.calcite.rel.AbstractRelNode.explain(AbstractRelNode.java:246)
at
org.apache.flink.table.planner.plan.nodes.FlinkRelNode.getRelDetailedDescription(FlinkRelNode.scala:50)
at
org.apache.flink.table.planner.plan.nodes.FlinkRelNode.getRelDetailedDescription$(FlinkRelNode.scala:46)
at
org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalRank.getRelDetailedDescription(StreamPhysicalRank.scala:41)
at
org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.createNewNode(FlinkChangelogModeInferenceProgram.scala:701)
at
org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.$anonfun$visitRankStrategies$1(FlinkChangelogModeInferenceProgram.scala:738)
at
org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.$anonfun$visitRankStrategies$1$adapted(FlinkChangelogModeInferenceProgram.scala:730)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at
org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.visitRankStrategies(FlinkChangelogModeInferenceProgram.scala:730)
at
org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.visit(FlinkChangelogModeInferenceProgram.scala:489)
Seems there is an embeded StringUtils in
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar. which confilict with other
class.
What should i do?
Do I have to manually excude StringUtils.class in
flink-sql-connector-hive-2.2.0_2.11-1.14.4.jar?
