flink使用table API報錯記錄

1、報錯記錄:

Caused by: java.lang.NoClassDefFoundError: scala/util/parsing/combinator/Parsers$class
        at org.apache.flink.table.expressions.ExpressionParser$.<init>(ExpressionParser.scala:40)
        at org.apache.flink.table.expressions.ExpressionParser$.<clinit>(ExpressionParser.scala)
        at org.apache.flink.table.api.java.StreamTableEnvironment.registerDataStream(StreamTableEnvironment.scala:128)
        at com.ly.engine.Engine.main(Engine.java:32)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421)
        at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)
        ... 8 more
Caused by: java.lang.ClassNotFoundException: scala.util.parsing.combinator.Parsers$class
        at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        ... 19 more

還有可能是

Caused by: java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;
        at org.apache.flink.table.api.TableEnvironment$.getFieldNames(TableEnvironment.scala:1360)
        at org.apache.flink.table.api.TableEnvironment.getFieldInfo(TableEnvironment.scala:1035)
        at org.apache.flink.table.api.StreamTableEnvironment.registerDataStreamInternal(StreamTableEnvironment.scala:519)
        at org.apache.flink.table.api.java.StreamTableEnvironment.registerDataStream(StreamTableEnvironment.scala:107)
        at com.ly.engine.Engine.main(Engine.java:32)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421)
        at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)
        ... 8 more

2、解決辦法:
第一次想到的是看官方文檔看依賴加載,一看官網(wǎng):


image.png

這依賴加載和我本地版本一模一樣,就是啟動不了。然后看了下運行環(huán)境的flink的版本也對應。于是看了下運行flink的依賴,在安裝目錄的lib和opt下面。lib下面是沒有和table相關的依賴了,看了下opt。


image.png

一看怎么是table和scala版本怎么是2.12版本的??磥砉倬W(wǎng)文檔也不是很完善啊。把幾個版本改成2.12完美運行。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

  • 這將是一套完整詳細且持續(xù)更新的、長期維護的 原創(chuàng) Flink系列教程、文檔,其中會包含各種商用實例詳解、Flin...
    Z盡際閱讀 2,992評論 4 8
  • 這將是一套完整詳細且持續(xù)更新的、長期維護的 原創(chuàng) Flink系列教程、文檔,其中會包含各種商用實例詳解、Flin...
    Z盡際閱讀 3,269評論 2 5
  • 一、Flink安裝 1.1 二進制安裝 在官網(wǎng)下載頁面下載二進制包,下載的壓縮包需要和服務器環(huán)境中的Hadoo...
    data之道閱讀 627評論 0 2
  • 聊聊今早發(fā)生的這件小事情吧! 早上快八點了,特別想出去洗澡,突然受不了,就抓起沐浴筐去家邊一個簡單的洗浴中心。 因...
    南洋杉閱讀 1,616評論 0 0
  • 午后1:30,中午和老公約在單位附近的串吧吃了個飯,然后走回辦公室上班——在這種37、8度又極端悶熱的天氣。兩個人...
    溫柔的小胖妞閱讀 225評論 0 0

友情鏈接更多精彩內(nèi)容