非常感谢！
发件人： 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, k8s集群为session
大家好，遇到一个问题：
坏境：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
这个类加
我也遇到这个问题，集群可以提交正常提交任务，但是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 org.apache.flink.runtime.rpc.akka.AkkaRpcServ
