回复: Re: 扩展SqlServerDialect 运行在flink on k8s报错

2021-05-07 Thread 18756225...@163.com
非常感谢! 发件人: Leonard Xu 发送时间: 2021-05-07 14:26 收件人: user-zh 主题: Re: 扩展SqlServerDialect 运行在flink on k8s报错 Hi 看日志是加载不到对应的class文件,(1)可以对比下你jar包里的路径是不是不正确,(2) 检查下集群上是不是还有之前的jar包,没替换干净 祝好 Leonard > 在 2021年5月7日,13:58,18756225...@163.com 写道: > > 大家好,遇到一个问题: > 坏境:flink 版本1.12.1,

扩展SqlServerDialect 运行在flink on k8s报错

2021-05-07 Thread 18756225...@163.com
大家好,遇到一个问题: 坏境:flink 版本1.12.1, k8s集群为session模式, 该集群之前可以将数据正常写入到mysql 参考mysqlDialect 扩展了一个 SqlServerDialect,替换了flink的lib包下的flink-connector-jdbc_2.11-1.12.1.jar,在on yarn时 任务正常运行,flink-sql也可以将数据写入到sqlserver 在同一台机器坏境 提交到k8s搭建的flink session模式集群, 就报如下错误 , JdbcBatchingOutputFormat

回复: flink 1.12.0 k8s session部署异常

2021-03-24 Thread 18756225...@163.com
我也遇到这个问题,集群可以提交正常提交任务,但是jobmanager的日志一直有这个, 请问可有办法解决? 发件人: casel.chen 发送时间: 2021-02-07 16:33 收件人: user-zh@flink.apache.org 主题: flink 1.12.0 k8s session部署异常 在k8s上部署sesson模式的flink集群遇到jobmanager报如下错误,请问这是什么原因造成的?要如何fix? 2021-02-07 08:21:41,873 INFO