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

解决办法:

添加以下依赖

            org.apache.flink

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

            ${flink.version}

            org.apache.flink

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

            ${flink.version}

            provided