【Flink】Windows环境部署Flink 1.10版本问题解决

摘要:
在Windows环境部署Flink1.10版本,发现TaskManager启动失败,看日志主要是几个内存参数没有配置导致的,简单记录一下。

在Windows环境部署Flink 1.10版本,发现TaskManager启动失败,看日志主要是几个内存参数没有配置导致的,简单记录一下。

直接通过start-cluster.bat启动会拉起JobManager和TaskManager,如果下列参数不配置的话,TaskManager进程会退出,日志显示相关的参数没有配置,在conf/flink-conf.yaml中添加下面的配置,重新启动即可:

taskmanager.cpu.cores: 2
taskmanager.memory.task.heap.size: 512m
taskmanager.memory.managed.size: 512m
taskmanager.memory.network.min: 64m
taskmanager.memory.network.max: 64m

免责声明:文章转载自《【Flink】Windows环境部署Flink 1.10版本问题解决》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇事务,Oracle,MySQL及Spring事务隔离级别mongodb进阶一之高级查询下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Flink on Yarn运行机制

从图中可以看出,Yarn的客户端需要获取hadoop的配置信息,连接Yarn的ResourceManager。所以要有设置有 YARN_CONF_DIR或者HADOOP_CONF_DIR或者HADOOP_CONF_PATH,只要设置了其中一个环境变量,就会被读取。如果读取上述的变量失败了,那么将会选择hadoop_home的环境变量,都区成功将会尝试加载...

Flink 如何实时分析 Iceberg 数据湖的 CDC 数据

简介: 数据湖的架构中,CDC 数据实时读写的方案和原理 本文由李劲松、胡争分享,社区志愿者杨伟海、李培殿整理。主要介绍在数据湖的架构中,CDC 数据实时读写的方案和原理。文章主要分为 4 个部分内容: 常见的 CDC 分析方案 为何选择 Flink + Iceberg 如何实时写入读取 未来规划 一、常见的 CDC 分析方案 我们先看一下今天的 to...

Flink作业使用windows的nc命令产生socket流

首先windows安装netcat 1 在命令行窗口使用  nc -lp 8888 2  开启Flink任务(socket源的datastream) 3  在命令行输入内容:  作业停止后nc自动停止  在使用中必须按照1,2,3的顺序,否则在命令行输入字符无效,或Flink作业启动失败。踩过的坑记录一下...

Flink 源码(二): Flink Client 实现原理与源码解析(一)

来源:https://mp.weixin.qq.com/s/WiRyQEoDfuowT3LNfZ-NSw 0 本文大纲: 一、我们本次的目的是什么? 这次我们的目的是,在本地的 IDEA 中去 debug flink-clients 代码,然后远程提交给 flink standalone 集群上去执行,看一看 flink 客户端在提交代码之前都干了什么。...

Flink1.13.2版本 Standalone 模式部署

Flink的部署有3种模式,分别是local模式、Standalone模式、yarn模式。其中local就是单机模式,一般来说用于本地开发测试;Standalone跟yarn模式都可以支撑集群部署、实现HA,但是两者在任务分配机制、内存管理等内容上有比较大的差异。一般在处理计算数据量级非常大的生产环境,使用flink on yarn的模式更多一些。 我们的...

Flink 读写 iceberg

iceberg 0.11 发布的时候稍微尝试了一下,发现实际并没有说的那么厉害,很多功能其实还在开发中(比如: upsert) 贴段之前写的 flink sql: # HADOOP_HOME is your hadoop root directory after unpack the binary package. export HADOOP_CLASS...