热门搜索:
您现在的位置是：首页 > 文章详情

LocalFlinkMiniCluster启动DataStream任务的流程

日期：2019-04-21点击：434

LocalFlinkMiniCluster 集群的actor 模型

  • 相关的主要类图如下：

image-20190415180352502.png

  • AkkaRpcActor持有一个rpcEndpoint成员，接收到消息后进行基础解析后调用rpcEndpoint的的对应方法来进行处理。
  • 其中RpcGateway及RpcEndPoint的类图
    image-20190415175424225.png

  • 支持的消息类型

    • 其中主要使用RpcInvocation基于反射调用RPCEndpoint的对应函数
    • FencedMessage 将message进行封装成payload，通过fencingToken进行校验，保证请求的合法性
      image-20190415175913490.png

LocalFlinkMiniCluster集群的角色

  • ResouceManager

    • 负责容器的分配
    • 使用FencedAkkaRpcActor实现，其rpcEndpoint为 org.apache.flink.runtime.resourcemanag
原文链接：https://yq.aliyun.com/articles/699245
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

相关文章

    文章评论

    共有0条评论来说两句吧...

    文章二维码

    扫描即可查看该文章

    点击排行

    推荐阅读

    最新文章