栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink TableAPI 报错--->类找不到

Flink TableAPI 报错--->类找不到

控制台报错:

"C:Program FilesJavajdk1.8.0_201binjava.exe" "-javaagent:D:ideaSoftwareIntelliJ IDEA 2020.2.3libidea_rt.jar=52126:D:ideaSoftwareIntelliJ IDEA 2020.2.3bin" -Dfile.encoding=UTF-8 -classpath "C:Program FilesJavajdk1.8.0_201jrelibcharsets.jar;C:Program FilesJavajdk1.8.0_201jrelibdeploy.jar;C:Program FilesJavajdk1.8.0_201jrelibextaccess-bridge-64.jar;C:Program FilesJavajdk1.8.0_201jrelibextcldrdata.jar;C:Program FilesJavajdk1.8.0_201jrelibextdnsns.jar;C:Program FilesJavajdk1.8.0_201jrelibextjaccess.jar;C:Program FilesJavajdk1.8.0_201jrelibextjfxrt.jar;C:Program FilesJavajdk1.8.0_201jrelibextlocaledata.jar;C:Program FilesJavajdk1.8.0_201jrelibextnashorn.jar;C:Program FilesJavajdk1.8.0_201jrelibextsunec.jar;C:Program FilesJavajdk1.8.0_201jrelibextsunjce_provider.jar;C:Program FilesJavajdk1.8.0_201jrelibextsunmscapi.jar;C:Program FilesJavajdk1.8.0_201jrelibextsunpkcs11.jar;C:Program FilesJavajdk1.8.0_201jrelibextzipfs.jar;C:Program FilesJavajdk1.8.0_201jrelibjavaws.jar;C:Program FilesJavajdk1.8.0_201jrelibjce.jar;C:Program FilesJavajdk1.8.0_201jrelibjfr.jar;C:Program FilesJavajdk1.8.0_201jrelibjfxswt.jar;C:Program FilesJavajdk1.8.0_201jrelibjsse.jar;C:Program FilesJavajdk1.8.0_201jrelibmanagement-agent.jar;C:Program FilesJavajdk1.8.0_201jrelibplugin.jar;C:Program FilesJavajdk1.8.0_201jrelibresources.jar;C:Program FilesJavajdk1.8.0_201jrelibrt.jar;D:Conding_pojoectMyFlinktargetclasses;D:MyToolsrepositoryorgapacheflinkflink-clients_2.121.9.3flink-clients_2.12-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-core1.9.3flink-core-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-annotations1.9.3flink-annotations-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-metrics-core1.9.3flink-metrics-core-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-asm-66.2.1-7.0flink-shaded-asm-6-6.2.1-7.0.jar;D:MyToolsrepositoryorgapachecommonscommons-lang33.3.2commons-lang3-3.3.2.jar;D:MyToolsrepositorycomesotericsoftwarekryokryo2.24.0kryo-2.24.0.jar;D:MyToolsrepositorycomesotericsoftwareminlogminlog1.2minlog-1.2.jar;D:MyToolsrepositoryorgobjenesisobjenesis2.1objenesis-2.1.jar;D:MyToolsrepositorycommons-collectionscommons-collections3.2.2commons-collections-3.2.2.jar;D:MyToolsrepositoryorgapachecommonscommons-compress1.18commons-compress-1.18.jar;D:MyToolsrepositoryorgapacheflinkflink-runtime_2.121.9.3flink-runtime_2.12-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-queryable-state-client-java1.9.3flink-queryable-state-client-java-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-hadoop-fs1.9.3flink-hadoop-fs-1.9.3.jar;D:MyToolsrepositorycommons-iocommons-io2.4commons-io-2.4.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-netty4.1.32.Final-7.0flink-shaded-netty-4.1.32.Final-7.0.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-jackson2.10.1-9.0flink-shaded-jackson-2.10.1-9.0.jar;D:MyToolsrepositoryorgjavassistjavassist3.19.0-GAjavassist-3.19.0-GA.jar;D:MyToolsrepositoryorgscala-langscala-library2.12.7scala-library-2.12.7.jar;D:MyToolsrepositorycomtypesafeakkaakka-actor_2.122.5.21akka-actor_2.12-2.5.21.jar;D:MyToolsrepositorycomtypesafeconfig1.3.3config-1.3.3.jar;D:MyToolsrepositoryorgscala-langmodulesscala-java8-compat_2.12.8.0scala-java8-compat_2.12-0.8.0.jar;D:MyToolsrepositorycomtypesafeakkaakka-stream_2.122.5.21akka-stream_2.12-2.5.21.jar;D:MyToolsrepositoryorgreactivestreamsreactive-streams1.0.2reactive-streams-1.0.2.jar;D:MyToolsrepositorycomtypesafessl-config-core_2.12.3.7ssl-config-core_2.12-0.3.7.jar;D:MyToolsrepositoryorgscala-langmodulesscala-parser-combinators_2.121.1.1scala-parser-combinators_2.12-1.1.1.jar;D:MyToolsrepositorycomtypesafeakkaakka-protobuf_2.122.5.21akka-protobuf_2.12-2.5.21.jar;D:MyToolsrepositorycomtypesafeakkaakka-slf4j_2.122.5.21akka-slf4j_2.12-2.5.21.jar;D:MyToolsrepositoryorgclappergrizzled-slf4j_2.121.3.2grizzled-slf4j_2.12-1.3.2.jar;D:MyToolsrepositorycomgithubscoptscopt_2.123.5.0scopt_2.12-3.5.0.jar;D:MyToolsrepositoryorgxerialsnappysnappy-java1.1.4snappy-java-1.1.4.jar;D:MyToolsrepositorycomtwitterchill_2.12.7.6chill_2.12-0.7.6.jar;D:MyToolsrepositorycomtwitterchill-java.7.6chill-java-0.7.6.jar;D:MyToolsrepositoryorgapacheflinkflink-optimizer_2.121.9.3flink-optimizer_2.12-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-java1.9.3flink-java-1.9.3.jar;D:MyToolsrepositorycommons-clicommons-cli1.3.1commons-cli-1.3.1.jar;D:MyToolsrepositoryorgslf4jslf4j-api1.7.15slf4j-api-1.7.15.jar;D:MyToolsrepositorycomgooglecodefindbugsjsr3051.3.9jsr305-1.3.9.jar;D:MyToolsrepositoryorgapacheflinkforce-shading1.9.3force-shading-1.9.3.jar;D:MyToolsrepositoryorgprojectlomboklombok1.18.2lombok-1.18.2.jar;D:MyToolsrepositoryorgapacheflinkflink-streaming-java_2.121.9.3flink-streaming-java_2.12-1.9.3.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-guava18.0-7.0flink-shaded-guava-18.0-7.0.jar;D:MyToolsrepositoryorgapachecommonscommons-math33.5commons-math3-3.5.jar;D:MyToolsrepositoryorgapachebahirflink-connector-redis_2.111.0flink-connector-redis_2.11-1.0.jar;D:MyToolsrepositoryorgapacheflinkflink-streaming-java_2.111.2.0flink-streaming-java_2.11-1.2.0.jar;D:MyToolsrepositoryorgapacheflinkflink-runtime_2.111.2.0flink-runtime_2.11-1.2.0.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-hadoop21.2.0flink-shaded-hadoop2-1.2.0.jar;D:MyToolsrepositoryorgtukaanixz1.0xz-1.0.jar;D:MyToolsrepositoryxmlencxmlenc.52xmlenc-0.52.jar;D:MyToolsrepositorycommons-codeccommons-codec1.4commons-codec-1.4.jar;D:MyToolsrepositorycommons-netcommons-net3.1commons-net-3.1.jar;D:MyToolsrepositoryjavaxservletservlet-api2.5servlet-api-2.5.jar;D:MyToolsrepositoryorgmortbayjettyjetty-util6.1.26jetty-util-6.1.26.jar;D:MyToolsrepositorycomsunjerseyjersey-core1.9jersey-core-1.9.jar;D:MyToolsrepositorycommons-elcommons-el1.0commons-el-1.0.jar;D:MyToolsrepositorycommons-loggingcommons-logging1.1.3commons-logging-1.1.3.jar;D:MyToolsrepositorycomjamesmurtyutilsjava-xmlbuilder.4java-xmlbuilder-0.4.jar;D:MyToolsrepositorycommons-langcommons-lang2.6commons-lang-2.6.jar;D:MyToolsrepositorycommons-configurationcommons-configuration1.7commons-configuration-1.7.jar;D:MyToolsrepositorycommons-digestercommons-digester1.8.1commons-digester-1.8.1.jar;D:MyToolsrepositoryorgcodehausjacksonjackson-core-asl1.8.8jackson-core-asl-1.8.8.jar;D:MyToolsrepositoryorgcodehausjacksonjackson-mapper-asl1.8.8jackson-mapper-asl-1.8.8.jar;D:MyToolsrepositoryorgapacheavroavro1.7.7avro-1.7.7.jar;D:MyToolsrepositorycomthoughtworksparanamerparanamer2.3paranamer-2.3.jar;D:MyToolsrepositorycomjcraftjsch.1.42jsch-0.1.42.jar;D:MyToolsrepositorycommons-beanutilscommons-beanutils-bean-collections1.8.3commons-beanutils-bean-collections-1.8.3.jar;D:MyToolsrepositorycommons-daemoncommons-daemon1.0.13commons-daemon-1.0.13.jar;D:MyToolsrepositoryjavaxxmlbindjaxb-api2.2.2jaxb-api-2.2.2.jar;D:MyToolsrepositoryjavaxxmlstreamstax-api1.0-2stax-api-1.0-2.jar;D:MyToolsrepositoryjavaxactivationactivation1.1activation-1.1.jar;D:MyToolsrepositoryionettynetty-all4.0.27.Finalnetty-all-4.0.27.Final.jar;D:MyToolsrepositorycomdata-artisansflakka-actor_2.112.3-customflakka-actor_2.11-2.3-custom.jar;D:MyToolsrepositorycomdata-artisansflakka-remote_2.112.3-customflakka-remote_2.11-2.3-custom.jar;D:MyToolsrepositoryionettynetty3.8.0.Finalnetty-3.8.0.Final.jar;D:MyToolsrepositoryorguncommonsmathsuncommons-maths1.2.2auncommons-maths-1.2.2a.jar;D:MyToolsrepositorycomdata-artisansflakka-slf4j_2.112.3-customflakka-slf4j_2.11-2.3-custom.jar;D:MyToolsrepositoryorgclappergrizzled-slf4j_2.111.0.2grizzled-slf4j_2.11-1.0.2.jar;D:MyToolsrepositorycomgithubscoptscopt_2.113.2.0scopt_2.11-3.2.0.jar;D:MyToolsrepositorycomfasterxmljacksoncorejackson-core2.7.4jackson-core-2.7.4.jar;D:MyToolsrepositorycomfasterxmljacksoncorejackson-databind2.7.4jackson-databind-2.7.4.jar;D:MyToolsrepositorycomfasterxmljacksoncorejackson-annotations2.7.0jackson-annotations-2.7.0.jar;D:MyToolsrepositoryorgapachezookeeperzookeeper3.4.6zookeeper-3.4.6.jar;D:MyToolsrepositoryorgslf4jslf4j-log4j121.6.1slf4j-log4j12-1.6.1.jar;D:MyToolsrepositorylog4jlog4j1.2.16log4j-1.2.16.jar;D:MyToolsrepositoryjlinejline.9.94jline-0.9.94.jar;D:MyToolsrepositoryjunitjunit3.8.1junit-3.8.1.jar;D:MyToolsrepositorycomtwitterchill_2.11.7.4chill_2.11-0.7.4.jar;D:MyToolsrepositoryorgapacheflinkflink-clients_2.111.2.0flink-clients_2.11-1.2.0.jar;D:MyToolsrepositoryorgapacheflinkflink-optimizer_2.111.2.0flink-optimizer_2.11-1.2.0.jar;D:MyToolsrepositoryorgapacheslingorg.apache.sling.commons.json2.0.6org.apache.sling.commons.json-2.0.6.jar;D:MyToolsrepositoryredisclientsjedis2.8.0jedis-2.8.0.jar;D:MyToolsrepositoryorgapachecommonscommons-pool22.3commons-pool2-2.3.jar;D:MyToolsrepositoryorgapacheflinkflink-statebackend-rocksdb_2.121.10.1flink-statebackend-rocksdb_2.12-1.10.1.jar;D:MyToolsrepositorycomdata-artisansfrocksdbjni5.17.2-artisans-2.0frocksdbjni-5.17.2-artisans-2.0.jar;D:MyToolsrepositorymysqlmysql-connector-java8.0.25mysql-connector-java-8.0.25.jar;D:MyToolsrepositorycomgoogleprotobufprotobuf-java3.11.4protobuf-java-3.11.4.jar;D:MyToolsrepositoryorgapacheflinkflink-table-planner_2.121.10.1flink-table-planner_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-table-common1.10.1flink-table-common-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-shaded-asm-77.1-9.0flink-shaded-asm-7-7.1-9.0.jar;D:MyToolsrepositoryorgapacheflinkflink-table-api-java-bridge_2.121.10.1flink-table-api-java-bridge_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-table-api-scala-bridge_2.121.10.1flink-table-api-scala-bridge_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-scala_2.121.10.1flink-scala_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-streaming-scala_2.121.10.1flink-streaming-scala_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-table-planner-blink_2.121.10.1flink-table-planner-blink_2.12-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-table-api-java1.10.1flink-table-api-java-1.10.1.jar;D:MyToolsrepositoryorgapacheflinkflink-table-api-scala_2.121.10.1flink-table-api-scala_2.12-1.10.1.jar;D:MyToolsrepositoryorgscala-langscala-reflect2.12.7scala-reflect-2.12.7.jar;D:MyToolsrepositoryorgscala-langscala-compiler2.12.7scala-compiler-2.12.7.jar;D:MyToolsrepositoryorgscala-langmodulesscala-xml_2.121.0.6scala-xml_2.12-1.0.6.jar;D:MyToolsrepositoryorgapacheflinkflink-table-runtime-blink_2.121.10.1flink-table-runtime-blink_2.12-1.10.1.jar;D:MyToolsrepositoryorgcodehausjaninojanino3.0.9janino-3.0.9.jar;D:MyToolsrepositoryorgcodehausjaninocommons-compiler3.0.9commons-compiler-3.0.9.jar;D:MyToolsrepositoryorgapachecalciteavaticaavatica-core1.15.0avatica-core-1.15.0.jar;D:MyToolsrepositoryorgreflectionsreflections.9.10reflections-0.9.10.jar" Com.ZQQQ.TableAPI.Example
21:39:36,292 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit does not contain a setter for field modificationTime
21:39:36,293 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - Class class org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance.
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/configuration/ReadableConfig
	at org.apache.flink.table.planner.StreamPlannerFactory.create(StreamPlannerFactory.java:49)
	at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:120)
	at org.apache.flink.table.api.java.StreamTableEnvironment.create(StreamTableEnvironment.java:112)
	at org.apache.flink.table.api.java.StreamTableEnvironment.create(StreamTableEnvironment.java:83)
	at Com.ZQQQ.TableAPI.Example.main(Example.java:35)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.configuration.ReadableConfig
	at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	... 5 more

Process finished with exit code 1

报错原因:
就是因为Flink 版本和tableAPI 的版本不一致导致的。
解决办法:
把所有的pom.xml 中涉及到flink 版本的都换成一致的版本。

本人配置 pom.xml 文件:

  
    
        org.apache.flink
        flink-streaming-java_2.12
        1.10.1
    
    
    
        org.apache.bahir
        flink-connector-redis_2.11
        1.0
    
    
    
    
        org.apache.flink
        flink-statebackend-rocksdb_2.12
        1.10.1
    
	
        
    
    
        org.apache.flink
        flink-table-planner_2.12
        1.10.1
    
    
        org.apache.flink
        flink-table-planner-blink_2.12
        1.10.1
    	
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/710228.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号