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

flink源码编译-job提交

1、启动standalone集群的taskmanager

standalone集群中的taskmanager启动类为 TaskManagerRunner

2 打开master启动类
通过 ctrl+n快捷键,找到、并打开类:
org.apache.flink.runtime.taskexecutor.TaskManagerRunner
3 修改运⾏配置
基本完全按照master运⾏配置进⾏即可;
run org.apache.flink.streaming.examples.hitao.WorkCount ./demo.jar
就⼀个关于⽇志的配置稍微修改⼀下(⽇志⽂件的名称)
-Dlog.file=./log/flink-taskmanager-1.local.log -
Dlog4j.configuration=./conf/log4j.properties -
Dlog4j.configurationFile=./conf/log4j.properties -
Dlogback.configurationFile=./conf/logback.xml 6.3 修改flink-conf.yaml配置⽂件
找到项⽬根⽬录下的conf,打开其中的flink-conf.yaml
添加如下配置(主要就是taskmanager的各项内存配置,可根据⾃⼰的情况进⾏修改)
taskmanager.resource-id: tm_hitao
taskmanager.cpu.cores: 1
taskmanager.memory.task.heap.size: 512m
t askmanager.memory.managed.size: 512m
taskmanager.memory.network.min: 128m
taskmanager.memory.network.max: 128m
taskmanager.memory.task.off-heap.size: 0m
http://www.lryc.cn/news/331960.html

相关文章:

  • Mysql密码修改问题
  • 建独立站,对FP商家有什么好处?
  • 使用Postman进行websocket接口测试
  • Android音视频开发 - MediaMetadataRetriever 相关
  • 注解(Annotation)
  • 蓝桥杯:七步诗 ← bfs
  • Vue 如何快速上手
  • Vue3:组件间通信-provide和inject实现祖先组件与后代组件间直接通信
  • 微信小程序——小程序和页面生命周期详解
  • android studio中添加module依赖
  • 【.NET全栈】.NET全栈学习路线
  • 代码随想录阅读笔记-二叉树【二叉搜索树中的搜索】
  • 1、初识drf
  • 速盾:cdn高防御服务器租用有哪些好处
  • 【跟小嘉学 Linux 系统架构与开发】四、文件和目录的权限
  • ubuntu18.04图形界面卡死,鼠标键盘失灵, 通过MAC共享网络给Ubuntu解决!
  • ESG认证(ESG=环境、社会和治理 Environmental, Social, and Governance)
  • Cesium Viewer 类学习
  • 第十四届省赛大学B组(C/C++)子串简写
  • 深入浅出 -- 系统架构之微服务架构
  • YoloV8改进策略:下采样改进|自研下采样模块(独家改进)|疯狂涨点|附结构图
  • Python从0到100(十):Python集合介绍及运用
  • 实用技巧:如何取消app的截屏禁用
  • 【氮化镓】GaN SP-HEMT的栅极可靠性
  • Linux基础和进阶用法
  • Linux运维-SHELL编程之正则表达式与流编辑处理器
  • openGauss学习笔记-256 openGauss性能调优-使用Plan Hint进行调优-优化器GUC参数的Hint
  • flex:1的作用是什么?
  • Mysql安装(命令方式安装)
  • Vben Admin实战-系统管理之用户管理-(第12节)