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

Docker 部署 flink1.19.2

官方文档

Docker

注意事项

平台错误

WARNING: The requested image's platform (linux/arm64/v8) does not match the detected host platform (linux/amd64/v3) and no specific platform was requested

平台不一致,所以报错

内存分配器问题

By default, Flink image adopts jemalloc as default memory allocator. This behavior can be disabled by setting the 'DISABLE_JEMALLOC' environment variable to 'true'.

部署脚本

networks:flink-network:
services:jobmanager:image: flink:1.19.2-scala_2.12-java8ports:- "18081:8081"command: jobmanagernetworks:- flink-networkenvironment:- |FLINK_PROPERTIES=jobmanager.rpc.address: jobmanager#volumes:# - ./JobManager/conf/:/opt/flink/conf/taskmanager:image: flink:1.19.2-scala_2.12-java8depends_on:- jobmanagercommand: taskmanagerscale: 1networks:- flink-networkenvironment:- |FLINK_PROPERTIES=jobmanager.rpc.address: jobmanagertaskmanager.numberOfTaskSlots: 5#volumes:#  - ./TaskManager/conf/:/opt/flink/conf/

ps: 目录挂载存在文件格式报错,待解决。

示例项目

学习文档

Overview

Maven 命令

$ mvn archetype:generate                \-DarchetypeGroupId=org.apache.flink   \-DarchetypeArtifactId=flink-quickstart-java \-DarchetypeVersion=1.19.2

打包并添加任务

批处理执行完成

相关文章:

  • Golang 学习指南
  • 基于ArcGIS的洪水淹没分析技术-洪水灾害普查、风险评估及淹没制图中的实践技术
  • Rollup、Webpack、Esbuild 和 Vite 前端打包工具
  • django.db.models.query_utils.DeferredAttribute object
  • Go RPC 服务方法签名的要求
  • Spark-Streaming3
  • Nacos简介—4.Nacos架构和原理一
  • 树莓派超全系列教程文档--(44)如何在树莓派上编译树莓派内核
  • 如何实现一个可视化的文字编辑器(C语言版)?
  • 优考试V4.20机构版【附百度网盘链接】
  • RabbitMQ应用(基于腾讯云)
  • 基于定制开发开源AI智能名片S2B2C商城小程序的会员存量池构建策略研究
  • 区块链基石解码:分布式账本的运行奥秘与技术架构
  • 助力产业升级 | BMC安全启动方案上新了!
  • Mysql从入门到精通day6————时间和日期函数精讲
  • 【PINN】DeepXDE学习训练营(6)——function-mf_func.py
  • Redis远程链接应用案例
  • 打造企业级AI文案助手:GPT-J+Flask全栈开发实战
  • CSDN编辑文章时如何自动生成目录
  • 【软件工程】 白盒测试简介
  • 脱发后怎么把头发养回来?脱发自救指南来了
  • 中纪报:五一节前公开通报释放强烈信号,以铁律狠刹歪风邪气
  • 四川落马厅官周海琦受审,1000余人接受警示教育
  • 财政部下达农业生产防灾救灾资金3.76亿元,支持黄淮海等地抗旱保春播
  • 5月动漫|“爱死机”即将回归,《明末》或是下一个大IP?
  • 我国首个大型通用光谱望远镜JUST在青海启动建设