1)flink datastream api 批处理走batch mode,针对 反压stage,可以细粒度 操控并行度 、slot group 、opertor chain 大概就能解决掉吧。
-- 最近看到 flink 1.15 新增的一个特性——批处理自适应调度器:可以根据 数据量的大小 ,自动推导并行度。
2)flinksql 批处理,针对反压stage, 如果部署在k8s上,利用弹性扩缩容特性,主动给更多资源呢?
@青牛
- 针对 Flink 批处理能力现状怎么样?(与 spark 对比)
- CDH 集群安装问题?
- CDH6.3.2 安装,报错:Src file /opt/cloudera/parcels/.flood/CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel/CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel does not exist,各位大佬怎么解决?
- CDH6.3.2 安装,报错:Src file /opt/cloudera/parcels/.flood/CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel/CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel does not exist,各位大佬怎么解决?
- cdh 大数据平台搭建
- cdh 大数据平台搭建
- cdh 大数据平台搭建
- 数据仓库分层及模型设计