Flink安装部署
本文共 608 字，大约阅读时间需要 2 分钟。
一、独立进程模式（Standalone）
1.1 官网下载
1.2 修改flink-conf.yaml
cd ./confvim flink-conf.yaml
1.3 修改masters
cat masters
1.4 修改workers
cat workers
1.5 执行脚本，启动flink
cd .../bin/start-cluster.sh
1.6 Web页面
flink-conf.yaml 中 “Rest & web frontend” 部分，用于配置web前端信息
默认地址：http://localhost:8081/#/overview 
1.7 提交Job
方式1：平台提交
点击 “Submit New Job-》Add New“ 选择项目Jar包，如下图
点击 项目Jar包 会出现下图所示内容，添加完 类信息、程序启动参数、并行度等信息后，点击 “Submit” 按钮即可完成本次Job提交任务 
方式2：命令行提交 cd flink解压后的目录./bin/flink run -c com.test.sun.demo.StreamWordCount -p 3 /Users/sunxiaoke/IdeaProjects/FirstFlinkTest/target/FirstFlinkTest-1.0-SNAPSHOT.jar --host localhost --port 7777s
转载地址：http://luxii.baihongyu.com/
你可能感兴趣的文章
C++——内存分配方式详解
查看>>
C/C++——各种类型int、long、double、char表示范围（最大最小值）
查看>>
x86汇编语言——基本概念
查看>>
《C和指针》——将无符号整数转换为字符
查看>>
《C和指针》——stdarg宏简介
查看>>
《C和指针》——声明数组参数
查看>>
《C和指针》——数组的奇怪形式
查看>>
《C和指针》——指向数组的指针（逐个移动和逐行的区别）
查看>>
《C和指针》——字符数组和字符串常量的区别
查看>>
《C和指针》——数组的存储顺序
查看>>
C/C++——new一个二维数组
查看>>
C/C++——输入输出特别注意点
查看>>
C/C++——输入输出字符相关,cin.get()、getchar()和cin.getline()
查看>>
C/C++——一些与输入有关的istream类成员函数
查看>>
C/C++——打开文件读取数据的各种方式
查看>>
LeetCode 104. Maximum Depth of Binary Tree
查看>>
LeetCode 141. Linked List Cycle
查看>>
LeetCode 202. Happy Number
查看>>
LeetCode 203. Remove Linked List Elements
查看>>
LeetCode 412. Fizz Buzz
查看>>