??????????????flink on 
yarn??1??TaskManager??4??slot??TaskManager????4G??JobManager????1G??????BucketingSink????hdfs??3??checkpoint??????????????????100????3????????300????????????????????427????????427????*300=128100????=125KB????????????????80??????80????*300=24000????=23KB??????Flink
 ?? TaskManager?? jvm ??????????????????????????????????1G??
JVM (Heap/Non-Heap) 
Type     Committed   Used     Maximum
Heap     2.68 GB     863 MB   2.68 GB 
Non-Heap 84.3 MB     82.8 MB  -1 B 
Total    2.76 GB     946 MB   2.68 GB



????????3s chepoint 
????????????????hdfs????????????????3s??????????????????????????????????????????????

回复