暂无搜索历史
摘要:BypassMergeSortShuffle 是 SortShuffleManager 提供的最轻量 Shuffle Write 路径——它绕过排序、绕过...
摘要:JSON 是数据工程中最常见的半结构化格式,如何高效地将 JSON 转为类型安全的 Dataset[CaseClass]?本文从 spark.read.j...
摘要:Shuffle 是 Spark 作业中最昂贵的操作,也是性能瓶颈的高发区。Spark 2.0 起 SortShuffleManager 成为唯一的默认实现...
摘要:为什么你的分组 TopN 任务跑了 30 分钟还 OOM?答案通常是四个字——groupByKey。本文将二次排序和分组 TopN 作为两条优化主线,从反...
摘要:Spark Standalone 集群的 Master 节点是资源调度的核心,一旦宕机整个集群陷入瘫痪。Master HA 通过 ZooKeeper 实现...
摘要:Spark 1.x 的 Accumulator 接口存在严重设计缺陷:类型单调(IN=OUT)、无法自定义扩展、内置实现仅 4 种。Spark 2.0 引...
摘要:为什么 DAGScheduler 从不关心集群用的是 Standalone 还是 YARN?为什么 Master 从不关心 DAG 怎么切?这背后是 Sp...
摘要:你是否注意过 Spark UI 上的 "DAG Visualization" 图?那个有向无环图(DAG)不是凭空生成的——它是 Spark 从你写的每一...
摘要:Spark Worker 是 Standalone 集群中每台节点上的"大管家"。它负责向 Master 注册签到、每 15 秒发送心跳、接收 Maste...
摘要:DAGScheduler 拿到 finalRDD 后,如何一步步回溯出完整的 Stage DAG?为什么 Stage 内部可以 Pipeline 执行而 ...
很多人学 HDFS,注意力全在 NameNode 上——它是 Master、是大脑、是命门。可你有没有想过一个问题:一个 10GB 的文件,客户端读取时,Nam...
一个几百台机器的 HDFS 集群,NameNode 宕机了。有人很镇定地说:"别急,不是还有个 SecondaryNameNode 吗,它会顶上。"结果集群迟迟...
一个几百台机器的集群,NameNode 一宕机,整个文件系统立刻不可读写——DataNode 明明还在转,为什么谁都找不到数据?HDFS 的命门,为什么偏偏集中...
AI 技术分享
上一篇我们建立了 HDFS 的整体印象:Block 切分、三副本、主从架构。但不少同学合上文章还是会问:NameNode 到底把元数据放在哪?重启一次为什么那么...
很多人第一次接触 HDFS 时都有同样的困惑:它是个"分布式文件系统",却不能随便改文件、不支持多线程同时写、还特别怕小文件。这些反直觉的"缺点",恰恰是理解它...
很多人学完 Hadoop 介绍章,脑子里反而更乱了:HDFS、YARN、MapReduce、Hive、HBase、Zookeeper、Flume、CDH、HDP...
面对 TB、PB 级数据,垂直扩容为什么是死路?Hadoop 用一组普通机器给出了答案。本文从 HDFS、YARN、MapReduce 三大组件出发,讲透 Ha...
暂未填写公司和职称
暂未填写技能专长
暂未填写学校和专业