问题一:我使用flink on yarn启动了一个任务模式 怎么看这个会话的资源被当前任务占用了多少?
我使用flink on yarn启动了一个任务 yarn session模式 怎么看这个会话的资源被当前任务占用了多少?
参考答案:
应该看不了 ,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613249
问题二:Flink cdc中jobmanager有个solrd进程,是不是被挖矿病毒给感染了?
Flink cdc中jobmanager有个solrd进程,是不是被挖矿病毒给感染了?
参考答案:
https://zhuanlan.zhihu.com/p/85731835
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/613245
问题三:flinksql kafka连接器可以设置source并行度吗?
flinksql kafka连接器可以设置source并行度吗?
参考答案:
应该还没适配. datagen支持了. https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/release-notes/flink-1.19/#table-sql--api ,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/612862
问题四:Flink写入mysql后,数据少了一些,这种有什么解决办法呢?
Flink写入mysql后,数据少了一些,这种有什么解决办法呢?大概3万5的数据,丢失了20几条这样子
参考答案:
flink写mysql丢数?平白无故丢?正常来说flink做了ck不会丢数把,只可能写重重。这得排一下丢得那几条数据,怎么丢得。除非你任务重启了,ck存的offset跟你下次启动的offset有差距 ,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/612861
问题五:flink yarn session 模式中想把IP映射为主机hadoop 这个在哪里操作呢?
flink yarn session 模式中启动的flink任务链接是 http IP 想把IP映射为主机hadoop 这个在哪里操作呢?
参考答案:
etc/host添加主机名和ip,然后修改你主机的host文件不就可以了嘛,改了以后在flink配置文件中改成host,重启flink ,
关于本问题的更多回答可点击进行查看: