暂无图片
暂无图片
暂无图片
暂无图片
暂无图片
Flink安装与部署.doc
254
19页
17次
2022-11-02
免费下载

安装部署
前言
运行架构
二、本地模式

本地集群

原理

操作

测试

独立集群

高可用集群

前言

支持多种安装模式

:本地单机模式,学习测试时使用

:独立集群模式,

自带集群,开发测试环境使用

:独立集群高可用模式,

自带集群,开发测试及生产环境使用

:计算资源统一由

管理,生产环境使用
一、运行架构

应用程序运行时,应用提交、资源申请与任务分配、任务执行,由三部分组成:
FlinkClient

为提交
 
的客户端,可以是运行在任何机器上(与
 !"
环境连通即
可)。提交
 
后,

可以结束进程(
#"
的任务),也可以不结束并等待结果返回
MapReduce Client
yarn jar hadoop-mapreduce.jar WordCount input ouput
JobManager
主要负责调度
 
并协调
$
%
,从

处接收到
 

包等
资源后,会生成优化后的执行计划,并以
$
为单元调度到各个
$!"
去执行。
ResourceManager
ApplicationMaster
JobTracker
TaskManager
在启动的时候就设置好了槽位数(

),每个

能启动一个
$
$
为线程。
 !"
处接收需要部署的
$
,部署启动后,与自己的上游建立连接,接收数据
NodeManager
TaskTracker
附录:
!&
架构组成
二、本地模式
本地模式
!
表示
 !"
$!"
运行在一个
'!
进程中。

启动
%
交互式窗口
(()( (%%
流计算,执行如下命令
*$+#,-%.((/01/2-3////4)!,5,-667-44#,,53
44898,&4#,4,4
of 19
免费下载
【版权声明】本文为墨天轮用户原创内容,转载时必须标注文档的来源(墨天轮),文档链接,文档作者等基本信息,否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容,欢迎发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论

关注
最新上传
暂无内容,敬请期待...
下载排行榜
Top250 周榜 月榜