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

Flink1.19编译并Standalone模式本地运行

1.首先下载源码

2.本地运行

新建local_conf和local_lib文件夹,并且将编译后的文件放入对应的目录

2.1 启动前参数配置

2.1.2 StandaloneSessionClusterEntrypoint启动参数修改

 2.1.3 TaskManagerRunner启动参数修改

和StandaloneSessionClusterEntrypoint一样修改

-Dlog.file=./log/flink-taskmanager-1.local.log -Dlog4j.configuration=./alocal_conf/log4j.properties -Dlog4j.configurationFile=./alocal_conf/log4j.properties -Dlogback.configurationFile=./alocal_conf/logback.xml

2.2 启动

先启动StandaloneSessionClusterEntrypoint

再启动TaskManagerRunner

遇到的问题:

1.no scalac found to compile scala sources

2.最开始采用java11编译没问题运行出错,程序包sun.misc不存在 之后修改为java8

3.由于taskmanager的文件目录生成有特殊符号,在windows中文件目录不允许有特殊符号,所以修改这里


http://www.kler.cn/a/395331.html

相关文章:

  • react-rnd的使用(react使用拖拽,缩放组件)
  • 51c嵌入式~单片机合集2
  • 微信小程序——01开发前的准备和开发工具
  • 第四十五章 Vue之Vuex模块化创建(module)
  • Python 中.title()函数和.lower()函数
  • docker更改数据目录
  • 在C2M(Customer-to-Manufacturer)柔性制造模式下,算法
  • element-ui】使用el_upload上传文件无法动态修改action
  • Scala的set
  • Python学习------第八天
  • 万字长文解读深度学习——训练(DeepSpeed、Accelerate)、优化(蒸馏、剪枝、量化)、部署细节
  • 界面控件Kendo UI for Angular中文教程:如何构建带图表的仪表板?(一)
  • 跨域问题的产生和解决
  • 【MatLab手记】 --从0到了解超超超详过程!!!
  • JWT深度解析:Java Web中的安全传输与身份验证
  • 雷光联动自动化标校方法
  • Python自动化小技巧24——实现自动化输出模板表格报告
  • react 受控组件和非受控组件
  • 使用git命令实现对gitee仓库的下载、更新、上传、上传更新操作。
  • FluentUI使用
  • kafka 生产经验——数据积压(消费者如何提高吞吐量)
  • 图像处理技术椒盐噪声
  • [C++刷题] 基础小知识点(5) 数字反转\求数字位数
  • Vue2:脚手架 vue-cli
  • UDP/TCP 简述
  • Elasticsearch集群和Kibana部署流程