问题一:有个Flink问题咨询下,application模式需要怎么配置呢?
有个Flink问题咨询下,运行run-application --target kubernetes-application执行,想通过进程的返回码来决定作业是否成功,但是任务不论成功还是失败返回码都是0,session模式成功是0,失败是其他的,application模式需要怎么配置呢?
参考答案:
可以监听 Flink JobManager 的日志输出,从中获取作业的成功或失败信息。通常,当作业成功完成时,日志中会有相应的成功消息;如果作业失败,会有错误或异常信息。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613270
问题二:Flink mysql --> sqlserver反压严重,3分钟只能进去1万多条。有人碰到过吗?
Flink mysql --> sqlserver反压严重,3分钟只能进去1万多条。有人碰到过吗?有啥方案不
参考答案:
状态后端用rocksdb的话,状态一大就会很慢,换hashmap会好很多,但是内存占用会上去
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613269
问题三:Flink这种情况会是什么原因呢?
Flink作业的job manager运行一段时间后full gc就越来越频繁且耗时变长直到任务重启,但是看tm内存都正常,这种情况会是什么原因呢?
参考答案:
是不是task分配的内存太少了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613257
问题四:请教个Flink问题,会把starrocks 磁盘打满是什么原因?
请教个Flink问题,mysql同步到starrocks的时候配置了 'debezium.snapshot.mode' = 'when_needed',会把starrocks 磁盘打满是什么原因?如果不配置就会任务跑10几个小时然后提示没有配置snapshot.mode' = 'when_needed'
参考答案:
换成initial试试
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613255
问题五:Flink有没有人遇到这个问题?
Flink有没有人遇到这个问题? Container released on a lost node
flink程序运行几个小时就挂掉了,这个应该往哪个方向排查
参考答案:
一般这种看起来就是资源问题 ,
关于本问题的更多回答可点击进行查看: