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.mzph.cn/news/792885.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

RabbitMQ在云原生环境中部署和应用实践

一、RabbitMQ和云原生技术的关系 RabbitMQ是一种开源的、实现了先进的消息队列协议(AMQP)的消息队列软件。而云原生技术就是为在公共云、私有云以及其他各种云环境提供应用的一种方法。RabbitMQ和云原生技术在分布式系统和微服务架构中都起到了关键作用…

NIUSHOP完美运营版商城 虚拟商品全功能商城 全能商城小程序 智慧商城系统 全品类百货商城

完美运营版商城/拼团/团购/秒杀/积分/砍价/实物商品/虚拟商品等全功能商城 干干净净 没有一丝多余收据 还没过手其他站 还没乱七八走的广告和后门 后台可以自由拖曳修改前端UI页面 还支持虚拟商品自动发货等功能 挺不错的一套源码 前端UNIAPP 后端PHP 一键部署版本 源码免费…

腾讯云4核8G服务器性能怎么样?能用来干什么?

腾讯云4核8G服务器多少钱?腾讯云4核8G轻量应用服务器12M带宽租用价格646元15个月,活动页面 txybk.com/go/txy 活动链接打开如下图所示: 腾讯云4核8G服务器优惠价格 这台4核8G服务器是轻量应用服务器,详细配置为:轻量4核…

ros小问题之rosdep update time out问题

在另外一篇ROS 2边学边练系列的文章里有写碰到这种问题的解决方法(主要参考了其他博主的文章,只是针对ROS 2做了些修改调整),此处单拎出来方便查找。 在ROS 2中执行rosdep update时,报出如下错误: 其实原因…

elsint报错Delete `␍`eslintprettier/prettier

一,原因 这篇博客写得很清楚:解决VSCode Delete ␍eslint(prettier/prettier)错误_vscode 删除cr-CSDN博客 还有这篇文章,解决办法很详细:滑动验证页面 二,解决办法 根目录下新建.prettierrc.js文件 module.exports…

谷歌AI搜索革新:探索高级搜索服务背后的未来趋势

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗?订阅我们的简报,深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同,从行业内部的深度分析和实用指南中受益。不要错过这个机会,成为AI领…

vulhub中Apache Solr RemoteStreaming 文件读取与SSRF漏洞复现

Apache Solr 是一个开源的搜索服务器。在Apache Solr未开启认证的情况下,攻击者可直接构造特定请求开启特定配置,并最终造成SSRF或任意文件读取。 访问http://your-ip:8983即可查看Apache Solr后台 1.访问http://your-ip:8983/solr/admin/cores?indexI…

一致性hash问题(负载均衡原理)

一致性哈希问题 简介 一致性Hash是一种特殊的Hash算法,由于其均衡性、持久性的映射特点,被广泛的应用于负载均衡领域,如nginx和memcached都采用了一致性Hash来作为集群负载均衡的方案。 本文将介绍一致性Hash的基本思路,并讨论其…

gpt国内怎么用?最新版本来了

claude 3 opus面世后,这几天已经有许多应用,而其精确以及从不偷懒(截止到2024年3月11日还没有偷懒)的个性,也使得我们可以用它来首次完成各种需要多轮对话的尝试。 今天我们想要进行的一项尝试就是—— 如何从一个不知…

Python Django ORM使用简单的增,删,改,查

Django ORM(对象关系映射)是Django框架中用于与数据库交互的一个核心组件。它提供了一种方便、直观的方式来定义、查询和操作数据库中的数据。 1. 定义模型(Model) 首先,你需要通过定义模型来告诉Django你的数据应该…

正则表达式完全指南:语法、用法及JavaScript实例

🌟 前言 欢迎来到我的技术小宇宙!🌌 这里不仅是我记录技术点滴的后花园,也是我分享学习心得和项目经验的乐园。📚 无论你是技术小白还是资深大牛,这里总有一些内容能触动你的好奇心。🔍 &#x…

生成器、迭代器、可迭代对象

生成器、迭代器、可迭代对象 生成器 函数体中包含yield关键字的就是生成器 把生成 器传给 next(...) 函数时,生成器函数会向前,执行函数定义体中的 下一个 yield 语句,返回产出的值,并在函数定义体的当前位置暂停。等到再次遇到n…

深度学习与神经网络:从基础到前沿

深度学习与神经网络是人工智能领域中的重要分支,其应用范围涵盖图像识别、语音识别、自然语言处理等多个领域,对于推动人工智能技术的发展具有重要意义。本文将从深度学习的基础原理开始,逐步探讨神经网络的结构、训练方法,以及在…

认识 Redis 与 分布式

Redis 官网页面 Redis官网链接 Redis 的简介 Redis 是一个在内存中存储数据的中间件 一方面用于作为数据库,另一方面用于作为数据缓存,适用于分布式系统中 Redis 基于网络,进行进程间通信,把自己内存中的变量给别的进程&#xf…

Leetcode 300. 最长递增子序列

心路历程: 经典的子串/子序列的DP问题,这道题需要按照最后一个元素包含在子序列的角度去建模比较好做。 状态:以nums[i]为结尾的最长严格递增子序列的长度 动作候选集:每一个[0, i)之间满足比nums[i]小的元素 返回值&#xff1a…

Python超市商品管理系统

系统需要用户先登录,再进行操作,其中包含一下功能菜单 1、显示商品列表 2、增加商品信息 3、删除商品 4、设置商品折扣 5、修改商品价格信息 6、退出 a、使用列表嵌套字典的方式保存用户数据(包含用户名、密码、姓名)&#xff1…

C#/WPF Inno Setup打包程序

Inno Setup介绍 Inno Setup 是一个免费的 Windows 安装程序制作软件。第一次发表是在 1997 年,现在已经更新到Inno Setup 6了。Inno Setup是一个十分简单实用的打包小工具,可以按照我们自己的意愿设置功能,稳定性也很好。 官方网址&#xff1…

F - 创新型机器猫 高性能战斗机器人(遇到过的题,做个笔记)

我的代码&#xff1a; #include <iostream> #include <vector> using namespace std; int main() {string str;cin >> str;int dxy[][2] { {0,1},{1,0},{0,-1},{-1,0} }; //设置偏移量&#xff0c;按照右转顺序&#xff1a;北->东->南->西int now…

mvn怎么安装jar

要在 Maven 项目中安装一个 JAR 文件到本地 Maven 仓库&#xff0c;您可以使用 Maven 的 install:install-file 命令。这个命令可以将指定的 JAR 文件安装到本地 Maven 仓库中&#xff0c;以便在项目中引用。 下面是使用 install:install-file 命令安装 JAR 文件的基本语法&am…

Spring Boot 集成 RabbitMQ(一)

1、RabbitMQ 和 SpringBoot 的基础概念 RabbitMQ 是一个开源的 MQ &#xff08;Message Queue&#xff0c;消息队列&#xff09; 客户端服务器实现&#xff0c;遵循 AMQP(Advanced Message Queuing Protocol)协议。它允许应用发送消息并不直接传递到目标对象&#xff0c;而是通…