Re:Re:Re:sink jdbc超时问题(无心跳包)

2021-12-19 文章 Michael Ran
心跳没有,只有重试参数:sink.max-retries 在 2021-12-20 12:14:37,"Jeff" 写道: > > > >会有? 什么意思呢? 我现在用的是1.13.2没有呀,相关配置也没。 > > > > > > > > > > > >在 2021-12-20 10:43:05,"Michael Ran" 写道: >>会有判断连接是否有效,以及重试的操作 >>在 2021-12-20 11:39:23,"Jeff" 写道: >>>sink jdbc长时间未有数据写入后,再写数据时会出现连接超时问题,请问flink jdbc connector是否有像连接池那样的心跳功

Re:Re:sink jdbc超时问题(无心跳包)

2021-12-19 文章 Jeff
会有? 什么意思呢? 我现在用的是1.13.2没有呀,相关配置也没。 在 2021-12-20 10:43:05,"Michael Ran" 写道: >会有判断连接是否有效,以及重试的操作 >在 2021-12-20 11:39:23,"Jeff" 写道: >>sink jdbc长时间未有数据写入后,再写数据时会出现连接超时问题,请问flink jdbc connector是否有像连接池那样的心跳功能?

Re:sink jdbc超时问题(无心跳包)

2021-12-19 文章 Michael Ran
会有判断连接是否有效,以及重试的操作 在 2021-12-20 11:39:23,"Jeff" 写道: >sink jdbc长时间未有数据写入后,再写数据时会出现连接超时问题,请问flink jdbc connector是否有像连接池那样的心跳功能?

sink jdbc超时问题(无心跳包)

2021-12-19 文章 Jeff
sink jdbc长时间未有数据写入后,再写数据时会出现连接超时问题,请问flink jdbc connector是否有像连接池那样的心跳功能?

Re:flink on native k8s模式下CPU使用率不高问题

2021-12-19 文章 Jeff
升级版本没有用的,我用的是flink 1.13.2也遇到这个问题,原因是它request与limit相同,所以后来我改了它的源代码,你可以参考一下:https://github.com/jeff-zou/flink.git ,我主要是改了KubernetesUtils.java这个类,利用external resource传入参数来替换request 在 2021-12-18 09:15:06,"casel.chen" 写道: >所用flink版本是1.12.5,部署作业到native k8s设置的不管是 kubernetes.taskmanager

Re: kafka源码执行测试用例问题

2021-12-19 文章 Hang Ruan
应该先用mvn install 发布到本地仓库,这个依赖才可以被找到 Yuepeng Pan 于2021年12月17日周五 20:28写道: > Hi, Chen. > 如果是idea模式,可以尝试排查下pom中依赖项的scope。 > > > > Best, > Roc. > > > > > > 在 2021-12-17 17:41:32,"陈卓宇" <2572805...@qq.com.INVALID> 写道: > >您好社区: > > > >我在进行flink源码Kafka连接器部分进行测试用例运行 > > > >报错日志: > > > >[ERROR] > org.a