1.安装准备工作
下载flink
Apache Flink: 下载
解压
[doda@host166 bigdata]$ tar -zxvf flink-1.12.0-bin-scala_2.11.tgz
2.Flinnk的standalone模式安装
2.1修改配置文件并启动
修改,好像使用默认的就可以了
[doda@host166 conf]$ more flink-conf.yaml
启动
[doda@host166 bin]$ sh start-cluster.sh
2.2访问默认端口8081
http://172.21.72.166:8081/#/task-manager
2.3提交任务
指定类提交任务
[doda@host166 flink-1.12.0]$ ./bin/flink run -c com.ztesoft.flink.FlinkCDCNew flink-0.0.1-SNAPSHOT-jar-with-dependencies.jar
Setting HBASE_CONF_DIR=/etc/hbase/conf because no HBASE_CONF_DIR was set.
Job has been submitted with JobID ea66c66f01f7b8c0a110bd7475922e55
查看任务提交状态,修改数据,查看日志