需要对于yarn集群进行实时和离线作业的分离，就单独搞一个yarn，实时对于资源的竞争比较敏感，所以用了标签来做机器上的隔离来保证资源的隔离性
阅读全文…
yarn-label Scheduler
作者: inter12
日期: 12 二月, 2019
没有评论 | 28 views
kafka2.0源码计划之－broker clusterId
作者: inter12
日期: 13 十一月, 2018
没有评论 | 259 views
_clusterId 生成规则
在KafkaServer中调用的方式是getOrGenerateClusterId,生成唯一值
阅读全文…
kafka2.0源码计划之－broker总览
作者: inter12
日期: 12 十一月, 2018
没有评论 | 378 views
用了近两年的kafka 0.10.1.1版本后，我们终于要废弃它了。在这个版本上，可以说是吃尽了苦头，其中的问题有自身对于kafka的理解不深入，也有kafka自己的bug问题。当流量小的时候，一切看起来都是那么美好，当流量到千亿级别时候，就是另一回事情。
阅读全文…
Presto内存分配机制
作者: inter12
日期: 18 九月, 2018
没有评论 | 621 views
1.预留系统内存：SYSTEM_POOL＝ Runtime.getRuntime().maxMemory() * 0.4
阅读全文…
YARN－ResourceManager的整体剖析
作者: inter12
日期: 1 九月, 2018
没有评论 | 638 views
最近在查YARN的一些问题，就总结一下YARN中RM的整体代码模块
阅读全文…
spark各类节点启动JVM设置
作者: inter12
日期: 31 七月, 2018
没有评论 | 873 views
最近遇到的一个问题，spark job history 经常很卡，看了下内存情况。默认是看了1G，-Xmx1g.
阅读全文…