问题一:Flink运行报错如何排查?
Flink运行报错如何排查?
参考回答:
您好,字段转换有问题吧,java.lang.Long不能被强制转换为java.lang.Integer
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/614507
问题二:Flink这个问题怎么解决?
Flink这个问题怎么解决?
参考回答:
因为是cdas,所以会有binlog,所以会有元数据缓存。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/614502
问题三:flink程序运行几个小时就挂掉了,这个应该往哪个方向排查?
flink程序运行几个小时就挂掉了,这个应该往哪个方向排查?
参考回答:
nodemanager 上的container 被驱逐了 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/613265
问题四:flink 任务提交yarn 执行,yarn log有以上堆栈报错,是什么原因哈? 有遇到过的吗?
flink 任务提交yarn 执行,yarn log有以上堆栈报错,是什么原因哈? 有遇到过的吗?
参考回答:
这个好像是资源不够,你任务提交上云对应的队列,队列是不是内存或CPU的vcore没资源了。如果提交任务的时候没指定队列,他就是默认的到root根队列。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/613259
问题五:flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?
flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?
参考回答:
连接断了,加大下jdbc的连接时间实时
jdbc:mysql://localhost:3306/mydatabase?connectTimeout=5000
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/613256