t;> cfso3...@126.com>;退订
>> 发送时间: 2024年6月29日(星期六) 晚上8:24
>> 收件人: "user-zh">
>> 主题: Re: 这绝对算是bug
>>
>>
>>
>> 连接没问题,主要是tm一直在处理写入流,我也看了一下负载,其实不高,但就是不相应,导致报timeout,然后就是最开始那个错误!
>> 发自我的 iPhone
>>
>> > 在 2024年6月29日,16
连接没问题,主要是tm一直在处理写入流,我也看了一下负载,其实不高,但就是不相应,导致报timeout,然后就是最开始那个错误!
发自我的 iPhone
> 在 2024年6月29日,16:49,Zhanghao Chen 写道:
>
> Hi,从报错看是 JM 丢主了,导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢?
>
> Best,
> Zhanghao Chen
> ____
> From: Cuixb
> Sent: Sa
生产环境Flink 1.16.2
2024-06-29 09:17:23
java.lang.Exception: Job leader for job id 8ccdd299194a686e3ecda602c3c75bf3
lost leadership.
at
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl.lambda$null$2(TaskExecutor.java:2310)
at java.util.Optional.ifPresent(Opti