解决办法:在$FLINKX_HOME/jars目录下有这些驱动包,可以手动安装,也可以使用插件提供的脚本安装:
## windows平台
./install_jars.bat
## unix平台
./install_jars.sh
1.8_release版本对应flink1.8 1.10_release版本对应flink1.10 版本 不对应在standalone和yarn session模式提交时,会报错: Caused by: java.io.InvalidClassException: org.apache.flink.api.common.operators.ResourceSpec; incompatible types for field cpuCores
FlinkX启动脚本里面找的是lib目录下的所有jar包,而移动后lib中含有其他的jar包,这些jar包没有主类,因此报错 可以使用如下的命令运行: java -cp flinkx/lib/flinkx-client.jar com.dtstack.flinkx.launcher.Launcher -mode local -job /opt/flink/flink/deps/job/stream.json -flinkxDistDir flinkx/flinkx-dist