标签：Flink 04 部署 flink jobmanager sh port localhost

https://flink.apache.org/downloads.html

左侧 Downloads   Binaries，1.14.2，.tgz包，300M+大小

yarn模式需要hadoop支持，在Additional Components下面下载

解压 tar -zxvf flink-1.14.2-bin-scala_2.12.tgz

最主要的三个目录：

bin ：shell脚本文件

     start-cluster.sh  stop-cluster.sh   jobmanager.sh   taskmanager.sh 

     特别的：flink文件（没有.sh）

conf：yml配置文件

   flink-conf.yaml

       jobmanager.rpc.address: localhost    配置jobmanager

       jobmanager.rpc.port: 6123

       ......

       rest.port: 8081

       rest.address: localhost

   masters:配置jobmanager

   slaves:配置taskmanager，每行一个

lib：可用的库包，比如hadoop包

Standalone 模式

执行 ./start-cluster.sh 默认会启动一个standalonesession daemon和一个taskexecutor daemon

执行 jps 查看可以看到一个TaskManagerRunner和一个StandaloneSessionClusterEntrypoint

访问 localhost:8081，可以看到web页面

并行度优先级：代码中setParallelism(n)>提交job时候的设置的parallelism>flink-conf.yaml中parallelism.default设置的值

注意slot和task任务数的配置，可能存在任务提交失败的情况（slot资源不够）

命令行方式：   

./flink run -c   <mainClass> -p 3  <jarPath> --host localhost --port 7777

./flink cancel <jobId>

./flink list -a

Flink on Yarn 模式2种

Flink需要hadoop支持

Sesson Cluster

Per Job Cluster

Kubernetes部署（待整理）

 

标签：Flink,04,部署,flink,jobmanager,sh,port,localhost
来源： https://www.cnblogs.com/yb38156/p/15731959.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。