Flink错误:java.lang.ClassNotFoundException: org.apache.flink网站.shaded.calcite.com网站.google.common.base.扔掉的东西


0

我正在使用Flink来流式传输csv文件中的数据。我想用某种模式把它 transformation成表格式。为此,我使用了Flink-table_2.10-1.1.3.jar(table api),但是我得到了以下错误:

log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.typeutils.TypeExtractor).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/shaded/calcite/com/google/common/base/Throwables
    at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.create(JaninoRelMetadataProvider.java:450)
    at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.revise(JaninoRelMetadataProvider.java:460)
    at org.apache.calcite.rel.metadata.RelMetadataQuery.revise(RelMetadataQuery.java:186)
    at org.apache.calcite.rel.metadata.RelMetadataQuery.collations(RelMetadataQuery.java:484)
    at org.apache.calcite.rel.metadata.RelMdCollation.project(RelMdCollation.java:207)
    at org.apache.calcite.rel.logical.LogicalProject$1.get(LogicalProject.java:122)
    at org.apache.calcite.rel.logical.LogicalProject$1.get(LogicalProject.java:120)
    at org.apache.calcite.plan.RelTraitSet.replaceIfs(RelTraitSet.java:238)
    at org.apache.calcite.rel.logical.LogicalProject.create(LogicalProject.java:116)
    at org.apache.calcite.rel.logical.LogicalProject.create(LogicalProject.java:108)
    at org.apache.flink.api.table.plan.logical.Project.construct(operators.scala:90)
    at org.apache.flink.api.table.plan.logical.Project.construct(operators.scala:85)
    at org.apache.flink.api.table.plan.logical.LogicalNode.toRelNode(LogicalNode.scala:78)
    at org.apache.flink.api.table.Table.getRelNode(table.scala:66)
    at org.apache.flink.api.table.StreamTableEnvironment.translate(StreamTableEnvironment.scala:243)
    at org.apache.flink.api.java.table.StreamTableEnvironment.toDataStream(StreamTableEnvironment.scala:147)
    at table_streaming_test.main(table_streaming_test.java:90)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.calcite.com.google.common.base.Throwables
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 17 more

当我研究相应的jar时,相应的类就出现在那里。你能告诉我为什么会这样吗?

另外,我可以获得maven源代码以便在我的地方构建Flink table.jar吗?

2 答案


0

我对CEP库也有同样的问题。我添加到我的pom文件,但我一直得到类NotFoundException。我甚至通过IntelliJ将它打包到jar文件中,但是没有成功。

    如果您使用的是他们的flink quickstart原型,我认为在pom文件中还有一些其他的东西需要更改,以使其正常 job 。当我自己创建了一个干净的项目并添加了flink依赖项时,我再也没有遇到这种异常了。你可以试试看这个方法是否有效。

root据Flink网站上的表格和SQL文档:

注意:表API当前不是二进制分布的一部分。

0

我在flinkv1.4.2中也遇到了同样的问题。

我将opt文件夹中的flink-table_2.11-1.4.2.jar文件添加到lib文件夹中,并重新启动了flink。


我来回答

写文章

提问题

面试题