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