1)flink datastream api 批处理走batch mode，针对 反压stage，可以细粒度 操控并行度 、slot group 、opertor chain 大概就能解决掉吧。
-- 最近看到 flink 1.15 新增的一个特性——批处理自适应调度器：可以根据 数据量的大小 ，自动推导并行度。
2）flinksql 批处理，针对反压stage, 如果部署在k8s上，利用弹性扩缩容特性，主动给更多资源呢？
@青牛

@风中劲草 ,大哥你是怎么解决的？我之前碰过到这个没解决过。

@犀牛

   cdh集群安装失败后，除了parcel文件hash验证失败原因，我也怀疑过是我给的20G空间太小了。所以，参照了cdh单点安装的视频进行安装，将cdh单点的磁盘空间设置成了35G，给了4核，12G资源（我的电脑是8核，16G）。但是仍然报相同的错：CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel does not exist  ，然后我就愣在原地了。
 网上还有种说法，说是这个下载parcel文件的时候，文件受损，导致分配时，hash验证失败。也有人尝试更改manifest。

谢谢何老师，其实吧，我是偷懒了，把cdh 只装在了一个节点，给了8G 4核 50G。停掉agent，删除缓存，重新装，我也试过了(网上说在线安装这一步，看人品)几次。我Linux 服务器有备份，从零开始装的，装了两遍，都是到intall parcel 这一步卡住了。

Install parcels 这一步：报错
src file /opt/cloudera/parcels/.flood/CDH-6.3.2-1.cdh6.3.2.p0.1605554-el7.parcel...does not exist

我想问一下，老师，关闭selinux 这一步骤：
按照命令，依次输入
输入了grep ^SELINUX= /etc/selinux/config
显示 disable
当输入 ：getenforce
显示 disable ，不是permissive 怎么处理？
我重新 编辑 vi /etc/selinux/config 之后
可以将第一步的命令处理结果改成 enforcing
最后的permissive 怎么得到

zan