当前位置: 首页 > news >正文

Flink安装与使用

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

查看任务提交状态,修改数据,查看日志

http://www.lryc.cn/news/129634.html

相关文章:

  • CentOS系统环境搭建(七)——Centos7安装MySQL
  • 3.react useRef使用与常见问题
  • Axios使用CancelToken取消重复请求
  • 九耶丨阁瑞钛伦特-Spring boot与Spring cloud 之间的关系
  • 总结,由于顺丰的问题,产生了电脑近期一个月死机问题集锦
  • C#程序配置读写例子 - 开源研究系列文章
  • Angular中的管道Pipes
  • React入门 jsx学习笔记
  • sqlserver数据库中把一张表中的数据复制到另一张表中
  • el-table 多个表格切换多选框显示bug
  • UE5.2程序发布及运行问题记录
  • c语言strtol函数、strtod函数、strtoul函数浅悉
  • Spark第三课
  • LangChain手记 Chains
  • ONNX版本YOLOV5-DeepSort (rknn版本已经Ready)
  • MySQL的约束
  • Lnton羚通关于【PyTorch】教程:torchvision 目标检测微调
  • AMD fTPM RNG的BUG使得Linus Torvalds不满
  • idea 转换为 Maven Project 的方法
  • es1.7.2 按照_type先聚合,再按照时间二次聚合
  • pyqt5 如何修改QplainTextEdit 背景色和主窗口的一样颜色
  • 解决使用element ui时el-input的属性type=number,仍然可以输入e的问题。
  • ShardingSphere 可观测 SQL 指标监控
  • Redisson实现分布式锁示例
  • 使用Nginx作为一个普通代理服务器
  • chatglm2-6b模型在9n-triton中部署并集成至langchain实践 | 京东云技术团队
  • Shell编程之正则表达式(非常详细)
  • RNN模型简单理解和CNN区别
  • 【Axure高保真原型】JS日期选择器筛选中继器表格
  • android bp脚本