flink源码编译-job提交 - 码农知识堂

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
相关阅读:
大四web前端网页制作课作业——HTML+CSS+JavaScript仿小米手机商城网站(37页)
jsqlparser:基于语法分析实现SQL中的CAST函数替换
 太速科技-基于Xilinx Kintex-7 FPGA K7 XC7K325T PCIeX8 四路光纤卡
 设计模式-创建型模式（单例、工厂、建造、原型）
zookeeper
素问·六节藏象论原文
 大家都在用MySQL count(*)统计总数，到底有什么问题？
SpringBoot+ECharts+Html 字符云/词云案例详解
 ThreeJS-截屏下载pdf或者图片时白屏
 Linux基础开发工具学习
原文地址：https://blog.csdn.net/ycjunhua/article/details/137370237