AI 助理
备案控制台
开发者社区 问答 正文

Flink 程序在面对数据高峰期时应该怎样处理呢？

Flink 程序在面对数据高峰期时应该怎样处理呢？

展开
收起
游客vwuxaq6iqaowc 2021-12-08 15:00:48 502 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 游客hveo756ydhs3k

    推荐使用大容量的 Kafka 把数据先放到消息队列里面作为数据源，再使用 Flink 进行消费，不过这样的缺点就是会影响到一点实时性

    2021-12-08 15:00:57
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版数据 实时计算 Flink版程序 实时计算 Flink版程序数据 实时计算 Flink版高峰 实时计算 Flink版怎样处理
问答地址：
开发者社区 > 大数据 > 问答
相关问答
相同的程序一个在云flink产品部署时Managed Memory打满，另一个几乎没有占用，为什么？
187
3
0
Flink运行java程序，然后java -jar 运行的，怎么能做大full GC的时候 挂掉呢？
135
1
0
Flink sql中是怎样处理这类数据的呢？
73
1
0
flink cdc 里 昨天就用initial方式重跑了程序，到今天中午才出现的这个问题。怎么回事？
79
0
0
在Flink CDC中存在晚上批量插入有大概30分支的流量高峰， 是否有参数可控制读取速率？
67
0
0
flink cdc采集mysql after中只有不会null的字段要怎样处理？
92
0
0
Flink CDC这种在dws层sum(a)聚合，这种在dws聚合的时候怎样处理呢？
102
2
0
Flink CK和SP不设置自动清理的话，系统会怎样处理，一直堆积下去吗？
135
3
0
用Flink CDC2.1版本的时候，有没有方式可以程序重启后只读增量的，通过开启增量检查点能行吗？
82
1
0
请问Flinkcdc中 flink的状态如何存储，程序重启，可以继续使用这些状态？
273
2
0