环境:flink1.12
操作:1.flinksql程序连接mysql执行流作业,打jar包集群运行(mysql打入jar包内)。
2.在yarn session模式下运行报错,java.lang.ClassNotFoundException: com.mysql.jdbc.Driver。
3.在yarn-per-job模式下运行同一个jar,正常运行。
4.包内有redis依赖,两种模式均可运行。
5.flinksql 连接mysql配置如下:
环境:flink1.12
操作:1.flinksql程序连接mysql执行流作业,打jar包集群运行(mysql打入jar包内)。
2.在yarn session模式下运行报错,java.lang.ClassNotFoundException: com.mysql.jdbc.Driver。
3.在yarn-per-job模式下运行同一个jar,正常运行。
4.包内有redis依赖,两种模式均可运行。
5.flinksql 连接mysql配置如下: