240 发简信
IP属地:吉林
  • Resize,w 360,h 240
    Flink源码分析之StreamGraph

    StreamGraph是什么? StreamGraph顾名思义是流图,它描述的是一个数据流的拓补结构,包含了创建JobGraph的所有必要信息。...

  • Flink源码解析之Job提交(上)

    启动Job 大家可能都知道通过上面这条命令,就可以在Flink集群上部署一个Job,执行你想要的功能,那么具体这个Job是怎么提交到集群的机器上...

  • Flink源码解析之JobManager接收Job

    前一篇文章已经说过,JobManager的职责主要是接收Flink作业,调度Task,收集作业状态和管理TaskManager。那么本篇主要讲J...

  • Resize,w 360,h 240
    Flink源码解析之JobManager启动

    JobManager职责 JobManager的职责主要是接收Flink作业,调度Task,收集作业状态和管理TaskManager。它包含一个...

  • Resize,w 360,h 240
    Flink源码解析之Job提交(下)

    上一篇文章我们讲解了通过命令行将一个Job提交到TaskManager的整体过程,但是我们中间忽略了一些细节,比如Job提交到集群的哪些节点,J...