1。2Flink单机部署Flink核心源码解读

　　1。2Flink单机部署
　　Flink系统环境要求：
　　1。Flink可以运行在类UNIX系统上，比如：Linux，MacOSX，Cygwin（forWindows）
　　2。Flink使用Java开发，依赖JDK版本：Java8或者11
　　1。下载Flink软件包
　　Flink源码是使用Java和Scala混合编写，针对使用的Scala版本不同，官网网站提供了scala2。11和scala2。12两个版本软件包，下载地址：https：flink。apache。orgdownloads。html。本书内容都基于flink1。14。xbinscala2。12。tgz版本，并且使用CentOSLinuxrelease7。9操作系统进行讲解演示，如果有另外标注情况除外。
　　2。解压Flink软件包以及目录说明tarzxvfflink1。14。3binscala2。12。tgzCopt
　　执行上面命令会把Flink解压到opt目录下，解压完成后目录结构如下图〔rootlocalhost〕cdoptflink1。14。3〔rootlocalhostflink1。14。3〕ll总用量480drwxrwxrx。21000100040969月2221：23bindrwxrwxrx。2100010002639月2221：23confdrwxrwxrx。710001000769月2221：23examplesdrwxrwxrx。21000100040969月2221：23librwrr。1100010001135710月292019LICENSEdrwxrwxrx。21000100040969月2221：23licensesdrwxrxrx。21000100069月1519：52logrwrwr。1100010004584979月2221：23NOTICEdrwxrwxrx。31000100040969月2221：23optdrwxrwxrx。10100010002109月2221：23pluginsrwrr。11000100013091月302021README。txt
　　和大多数开源项目一样，Flink有bin、conf、lib、log目录，各目录功能说明：bin目录用于存放启动、停止相关脚本文件。例如startcluster。sh、yarnsession。sh、kubernetessession。sh、startzookeeperquorum。sh等conf目录用于存放配置文件。例如flinkconf。yaml、masters、workers、log4j。properties等lib目录用于存放依赖的二进制jar包。该目录下只有flinkdist2。121。14。3。jar、flinktable2。121。14。3。jar、flinkcsv1。14。3。jar、flinkshadedzookeeper3。4。14。jar、log4jslf4jimpl2。14。1。jar等文件log目录用于存放运行产生的日志文件。包括JobManager、TaskManager日志信息
　　3。配置JAVAHOME环境变量，编辑etcprofile文件，根据JDK安装路径JAVAHOME。exportJAVAHOMEusrjavajdk1。8。0exportPATHPATH：JAVAHOMEbin
　　执行sourceetcprofile让变更生效，验证是否生效〔rootlocalhost〕echoJAVAHOMEusrjavajdk1。8。0
　　JAVAHOME既可以通过修改操作系统环境变量来配置，也可以通过修改flinkconf。yaml文件来配置。如果都配置了则flinkconf。yaml优先级更高。打开文件flinkconf。yaml增加或修改配置项env。java。home输入jdk路径即完成配置env。java。home：usrjavajdk1。8。0
　　4。启动Flink。进入安装目录执行。binstartcluster。sh启动单机模式〔rootlocalhostflink1。14。3〕。binstartcluster。shStartingcluster。Startingstandalonesessiondaemononhostlocalhost。localdomain。Startingtaskexecutordaemononhostlocalhost。localdomain。〔rootlocalhostflink1。14。3〕
　　执行上面命令启动Flink单机模式，如果启动成功可以看到有2个flink相关进程，其中一个进程是jobmanager，它负责集群的任务协调，另外一个进程是taskmanager，它负责运行具体的任务作业，后续章节会详细阐述jobmanager、taskmanager职责
　　在linux系统运行jdk提供的jpsl命令，能看到两个进程的入口类：〔rootlocalhostflink1。14。3〕jpsl20886org。apache。flink。runtime。taskexecutor。TaskManagerRunner20615org。apache。flink。runtime。entrypoint。StandaloneSessionClusterEntrypoint21039sun。tools。jps。Jps
　　6。从浏览器访问http：host1。test。com：8081页面，如果能看到如下图的Flinkweb管理页面，则证明Flink启动成功。
　　如果有任何疑问欢迎留言，笔者头条号与公众号同名：小圈数据