汝阳网站建设哪家好,新加坡设计公司排行,失信被执行人,网站开发需要什么技术1.安装准备工作
下载flink
Apache Flink: 下载 解压 [dodahost166 bigdata]$ tar -zxvf flink-1.12.0-bin-scala_2.11.tgz
2.Flinnk的standalone模式安装 2.1修改配置文件并启动
修改#xff0c;好像使用默认的就可以了
[dodahost166 conf]$ more flink-conf.yaml
启动 …1.安装准备工作
下载flink
Apache Flink: 下载 解压 [dodahost166 bigdata]$ tar -zxvf flink-1.12.0-bin-scala_2.11.tgz
2.Flinnk的standalone模式安装 2.1修改配置文件并启动
修改好像使用默认的就可以了
[dodahost166 conf]$ more flink-conf.yaml
启动 [dodahost166 bin]$ sh start-cluster.sh
2.2访问默认端口8081
http://172.21.72.166:8081/#/task-manager 2.3提交任务
指定类提交任务
[dodahost166 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
查看任务提交状态修改数据查看日志
