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

Flink2支持提交StreamGraph到Flink集群

  1. 最近研究Flink源码的时候,发现Flink已经支持提交StreamGraph到集群了,替换掉了原来的提交JobGraph。在这里插入图片描述
    新增ExecutionPlan接口,将JobGraph和StreamGraph作为实现。
    在这里插入图片描述

Flink集群Dispatcher也进行了修改,从JobGraph改成了接口ExecutionPlan,以支持StreamGraph的提交。
在这里插入图片描述
2. Flink2还移除了Per-Job的部署模式。
3. flink run-application 脚本命令已经不再使用,改成了 flink run yarn-application或者flink run kubernetes-application。execution.target
在这里插入图片描述

http://www.lryc.cn/news/530240.html

相关文章:

  • 大模型本地化部署(Ollama + Open-WebUI)
  • C++哈希(链地址法)(二)详解
  • IME关于输入法横屏全屏显示问题-Android14
  • 网络工程师 (11)软件生命周期与开发模型
  • 【人工智能】基于Python的机器翻译系统,从RNN到Transformer的演进与实现
  • 网络工程师 (12)软件开发与测试
  • 3.Spring-事务
  • Python字典详解:从入门到实践
  • 91,【7】 攻防世界 web fileclude
  • 41【文件名的编码规则】
  • 蓝桥杯备赛经验帖
  • 一文大白话讲清楚webpack基本使用——17——Tree Shaking
  • 【C++ 区间位运算】3209. 子数组按位与值为 K 的数目|2050
  • 8 比例缩放(scale.rs)
  • 二分 机器人的跳跃问题
  • Hive:复杂数据类型之Map函数
  • R 字符串:深入理解与高效应用
  • 设计模式Python版 桥接模式
  • 记5(一元逻辑回归+线性分类器+多元逻辑回归
  • 【Python】第七弹---Python基础进阶:深入字典操作与文件处理技巧
  • Nginx 运维开发高频面试题详解
  • 下载OpenJDK
  • Web3.js详解
  • 学习串行通信
  • 【leetcode强化练习·二叉树】同时运用两种思维解题
  • Rank-analysis-1.2——一款基于LCU API的排位分析工具,大四学生独立开发
  • 什么是门控循环单元?
  • Google Chrome-便携增强版[解压即用]
  • 智慧园区综合管理系统如何实现多个维度的高效管理与安全风险控制
  • 【PyTorch】7.自动微分模块:开启神经网络 “进化之门” 的魔法钥匙