环境信息
flink-1.13.6_scala_2.11
java 1.8
使用的是standalonesession集群模式，node01为jobmanager node02和node03为taskmanager
自定义函数的代码
package com.example.udf;
import org.apache.flink.table.functions.ScalarFunction;
public class SubStr extends ScalarFunction {
public String eval(String s, Integer start,
我使用 ZooKeeper High-Availability with Standalone 集群模式，使用 sql-client.sh 提交任务
On 2022/04/20 10:43:16 Zhanghao Chen wrote:
> 你是用的什么 Flink 集群部署模式提交的 SQL 任务呢？
>
> Best,
> Zhanghao Chen
>
> From: 段晓雄
> Sent: Saturday, April 16, 2022 19:52
> To: user-zh@flink.apache.org
补充一个 case，检查下 hudi connector 是否使用了 OperatorCoordinator 来跟 hudi 进行一些交互，这部分操作是在
JobMaster 主线程内的，如果耗时比较长会导致 TaskManager 跟 JobMaster 断开链接.
> 2022年4月20日 下午6:42，Zhanghao Chen 写道：
>
> 出现 Job leader for job id lost 说明是 jm leader 在 zk 上的 session timeout
> 了。可能的原因有
>
> 1. JM 和 ZK 网络连接有抖动，ZK
你是用的什么 Flink 集群部署模式提交的 SQL 任务呢？
Best,
Zhanghao Chen
From: 段晓雄
Sent: Saturday, April 16, 2022 19:52
To: user-zh@flink.apache.org
Subject: RE: Re: Re: 日志里提示 The state is cleared because of state ttl. This will
result in incorrect result 如何解决？
Zhanghao,
感谢帮助！我在
Hi??all
??Flink kafkahudiJob leader for job id
lostleadership?? ?? flink
??zk??
??
??k8s on session
flink??1.13.6
java:1.8
??flink mongodb cdc ETL
2022-04-20 15:11:49,218 WARN
io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager [] - Exec
Failure
java.net.SocketException: Broken pipe (Write
??
??flink cdc
mongodbflink??web ui??Task
managersThread
Dump??dump??Dump
??
??
----
??:
"user-zh"
Hello, 卓宇：
这个是REST API的报错，说明你在Flink
Dashboard中TaskManager页面点击了Stdout选项卡，但对应的TaskManager上访问不到stdout文件，因此报错。该错误不会影响任务的正常运行，可以忽略。
Best,
Zhilong
On Wed, Apr 20, 2022 at 3:06 PM 陈卓宇 <2572805...@qq.com.invalid> wrote:
> 大佬您好：
> 小弟想问一下这个异常是什么原因产生的，对生产有何影响，如何消除
>
>
??
??
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException:
The file STDOUT does not exist on the TaskExecutor.
at
10 matches
Mail list logo
