Caused by: java.lang.ClassNotFoundException:org.apache.flink.connector.base.source.reader.RecordEmit

• 大数据

出现以下错误:

Exception in thread “main” java.lang.NoClassDefFoundError: org/apache/flink/connector/base/source/reader/RecordEmitter

Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.base.source.reader.RecordEmitter

Caused by: java.lang.ClassNotFoundException:org.apache.flink.connector.base.source.reader.RecordEmit

解决办法:

添加以下依赖

   <!– 如果不引入 flink-table 相关依赖，则会报错：

        Caused by: java.lang.ClassNotFoundException:org.apache.flink.connector.base.source.reader.RecordEmitter

        引入以下依赖可以解决这个问题（引入某些其它的 flink-table相关依赖也可）

        –>

       

            org.apache.flink

            flink-table-api-java-bridge_${scala.version}

            ${flink.version}

       

       

            org.apache.flink

            flink-table-planner-blink_${scala.version}

            ${flink.version}

            provided

       

 

 

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://net2asp.com/e462cf7d0e.html

赞 (0)
« 上一篇 1天前
下一篇 » 1天前

相关推荐