Flink2支持提交StreamGraph到Flink集群

news/2025/2/1 6:40:43 标签: flink, 大数据, Flink2, StreamGraph, JobGraph
  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.niftyadmin.cn/n/5839091.html

相关文章

PPT演示设置：插入音频同步切换播放时长计算

PPT演示设置：插入音频同步切换播放时长计算

PPT中插入音频&同步切换&放时长计算 一、 插入音频及音频设置二、设置页面切换和音频同步三、播放时长计算 一、 插入音频及音频设置 1.插入音频：点击菜单栏插入-音频-选择PC上的音频（已存在的音频）或者录制音频（现场录制…
阅读更多...
Koa 基础篇（二）—— 路由与中间件

Koa 基础篇（二）—— 路由与中间件

let app new Koa() router.get(“/”,async ctx > { ctx.body “hello koa router” }) app.use(router.routes()) app.use(router.allowedMethods()) app.listen(3000) 运行项目，在浏览器访问本地3000端口，在页面上就会看到输出的语句。这就…
阅读更多...
deepseek核心技术：MLA架构-多头潜在注意力

deepseek核心技术：MLA架构-多头潜在注意力

deepseek核心技术：MLA架构-多头潜在注意力 MLA架构即Multi-Head Latent Attention（多头潜在注意力）架构，是一种优化后的注意力机制。以下是对其及相关示例的具体介绍： 工作原理 输入嵌入：将输入序列中的每个元素转换为向量表示，即嵌入向量。例如在处理文本时，将文本中…
阅读更多...
Verilog边沿检测

Verilog边沿检测

edge_check.v module edge_check(input clk,input in,output neg_edge,output pos_edge);reg r11d0;reg r21d0;assign neg_edge(~r1)&r2;assign pos_edger1&(~r2);always(posedge clk)beginr1<in;r2<r1;endendmodule tb.v timescale 1ns/1nsmodule tb; //被测…
阅读更多...
数据库性能优化(sql优化)_SQL执行计划03_yxy

数据库性能优化(sql优化)_SQL执行计划03_yxy

数据库性能优化_SQL执行计划详解03 1 排序、聚集类操作符1.1 SORT 排序1.2 聚集AAGR 简单聚集FAGR 快速聚集HAGR HASH分组聚集SAGR 流分组聚集1.3 排序、聚集类操作符总结2 执行计划读取技巧1 排序、聚集类操作符 1.1 SORT 排序 它的主要功能是按照指定的列（或列组合）以及排…
阅读更多...
Vue.js组件开发-实现全屏焦点图片带图标导航按钮控制图片滑动切换

Vue.js组件开发-实现全屏焦点图片带图标导航按钮控制图片滑动切换

使用 Vue 实现全屏焦点图片带图标导航按钮控制图片滑动切换 步骤 创建 Vue 项目&#xff1a;可以使用 Vue CLI 快速创建一个新的 Vue 项目。设计组件结构&#xff1a;创建一个包含图片展示区域和导航按钮的组件。实现图片滑动切换逻辑&#xff1a;通过点击导航按钮切换图片。…
阅读更多...
2025-1-28-sklearn学习(47) (48) 万家灯火亮年至，一声烟花开新来。

2025-1-28-sklearn学习(47) (48) 万家灯火亮年至，一声烟花开新来。

文章目录 sklearn学习(47) & (48)sklearn学习(47) 把它们放在一起47.1 模型管道化47.2 用特征面进行人脸识别47.3 开放性问题: 股票市场结构 sklearn学习(48) 寻求帮助48.1 项目邮件列表48.2 机器学习从业者的 Q&A 社区 sklearn学习(47) & (48) 文章参考网站&…
阅读更多...
riscv xv6学习笔记

riscv xv6学习笔记

文章目录 前言util实验sleeputil实验pingpongutil实验primesxv6初始化代码分析syscall实验tracesyscall实验sysinfoxv6内存学习笔记pgtbl实验Print a page tablepgtbl实验A kernel page table per processxv6 trap学习trap实验Backtracetrap实验Alarmlazy实验Lazy allocationxv…
阅读更多...
最新文章

Copyright @ 2022~2023