问题一:Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?
Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?
参考答案:
state.checkpoints.dir: hdfs://namenode-host:port/path/to/checkpoints
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610802
问题二:Flink的binlog文件太多,导致全量后的增量阶段追赶很慢,这个有办法解决吗?
Flink的binlog文件太多,导致全量后的增量阶段追赶很慢,这个有办法解决吗?
参考答案:
目前只能加资源,开启自动调优。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610252
问题三:Flink这个一直在重跑 有什么办法可以让他停下来?
Flink这个一直在重跑 有什么办法可以让他停下来?
参考答案:
目前只能通过后台停止了,这方面已经提需求了,后面排期改一下。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610251
问题四:Flink1.17-vvr-8.0.4-1版本的ververica依赖中这个功能上了吗?
Flink1.17-vvr-8.0.4-1版本的ververica-connector-mysql依赖中这个功能上了吗?
参考答案:
上了。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610250
问题五:Flink cep有没有可以优化的地方?
Flink cep有没有可以优化的地方? 我从kafka写入kafka数据简单加工,几百万的数据几乎没延时, 然后同样的数据读取出来做了CEP处理,一晚上只处理了30W+就多了CEP部分处理 。
参考答案:
CEP是很吃状态和性能,可不是看起来简单的无状态处理。
关于本问题的更多回答可点击进行查看: