240 发简信
IP属地:北京
  • Resize,w 360,h 240
    Flink容错性机制-状态(State)的实现原理

    之前介绍了Checkpoint的组成之一Barrier,本文主要介绍State。当operator包含一些状态数据的时候,这些状态同样也是快照的...

  • Resize,w 360,h 240
    Flink 容错性机制- 屏障(barrier)实现原理

    我们知道Flink提供了容错机制,能够在应用失败的时候重新恢复任务。这个机制主要就是通过持续产生快照的方式实现的。Flink快照主要包括两部分数...

  • 故障分析模板

    【标题】2019XXXX-事故简单描述 【故障描述】 描述什么时间,出现了什么问题 【故障原因】 【时间范围】 【故障影响】 【修复办法】 【故...

  • Spark Repartition 使用

    看到一些同学的Spark代码中包含了很多repartition的操作,有一些不是很合理,非但没有增加处理的效率,反而降低了性能。这里做一个介绍。...

  • spark.sql.shuffle.partitions 和 spark.default.parallelism 区别

    上面两个参数都是设置默认的并行度,但是适用的场景不同: spark.sql.shuffle.partitions是对sparkSQL进行shuf...

  • Spark 任务开发的一些建议

    剖析需求,熟悉业务 熟悉需求以及业务接口 开发一个Spark的任务和开发其他需求是一样的,要知道这个任务主要用来做什么,输入时什么,输出是什么,...

  • Resize,w 360,h 240
    第四周 深层神经网络

    4.2 深层网络中的前向传播 4.3 核对矩阵的维数 主要是计算w的维数,以及b的维数 单个样本的情况如下所示 表示样本具有两个特征,因为是,是...

  • Resize,w 360,h 240
    第三周 浅层神经网络 笔记

    表示第i个样本表示样本的第i个特征 所以这里的x都是列向量 L(y,y)是单个损失函数 J 是所有训练样本的 逻辑回归可以被看成一个非常小的神经...

  • Spark 是否开启动态资源分配

    Spark提供了一种机制,使它可以根据工作负载动态调整应用程序占用的资源。这意味着,如果不再使用资源,应用程序可能会将资源返回给集群,并在稍后需...

个人介绍
纸上学来终觉浅,绝知此事要躬行。
多动手,多思考,多总结。
验证对一个问题的掌握程度:
第一级别 自己理解
第二级别 能够给别人讲明白
第三级别 能够自己解决、落地