flink标签_AtomGit开源社区

flink

本地 Flink on K8s + Iceberg + MinIO 实时数仓平台 — AI部署指南与踩坑实录

本文详细介绍了在 macOS 本地环境下搭建轻量级实时数仓平台的全过程。项目基于 Minikube 单集群，整合了 Apache Flink 1.19.1、Iceberg 1.10.2、MinIO 和 Kafka 等技术栈，实现 Kafka→Flink→Iceberg→MinIO 的数据流处理。文章包含环境准备、组件部署、核心配置及踩坑经验，重点解决了 Flink 与 Iceberg REST C

yyoc97
2026-06-11 18:03:41

 519

 8

#flink #kubernetes #大数据
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: org.apa

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: org.apa

BD_Marathon
2026-06-10 12:29:42

 241

 4

#flink
【AI大数据工程师特训笔记】第15讲：大数据环境安装

本文提供了一份完整的大数据组件安装指南，适用于WSL（Windows Subsystem for Linux）环境下的零基础用户。指南从WSL和Java环境安装开始，逐步指导用户安装和配置Hadoop、Hive、Spark、Flink、DolphinScheduler、DataX、Kafka、FlinkCDC和Iceberg等核心大数据组件。每个章节都包含详细的步骤说明、命令示例和验证方法，并配有

 tianp123
2026-06-10 10:19:00

 295

 3

#大数据 #spark #hadoop +1
大数据处理全家桶：Hadoop 是什么？Spark、Flink 们都是啥关系？

│ 离线批处理 ││ │ (翻译) │ │ 或 Spark │ ││▼│ HDFS (分布式存储) │▲│ 实时读写 │ 实时流计算 │组件一句话解释Hadoop大数据生态的老大哥，提供 HDFS（存储）和 MapReduce（计算）。HDFS把大文件拆碎、多备份存到很多电脑上，保证不丢数据。MapReduce分而治之的计算模型，但慢（每次写磁盘）。Spark用内存加速的通用计算引擎，比 MapR

是一个Bug
2026-06-09 10:52:50

 407

 6

#运维 #大数据 #spark +2
【字节跳动】FAISS索引增量更新/持久化、DIN完整离线训练数据集逻辑、Flink多流拼接、天盾全链路风控流水线、NCode协议二进制封包、GR3底层驱动帧格式、全局限流熔断、日志隐秘埋点、内存镜像

本文摘要：技术方案涵盖多个核心模块：1）FAISS索引支持增量更新与磁盘持久化；2）DIN模型实现离线数据集构造与完整训练流程；3）Flink多流（行为+画像）拼接计算用户兴趣衰减；4）天盾风控全链路流水线（特征抽取→评分→拦截决策）；5）NCode协议二进制封包与GR3机械臂驱动解析；6）全局令牌桶限流熔断机制；7）日志隐秘埋点与内存防篡改安全设计；8）统一鉴权网关与配置热加载能力。通过C++

季念&季凡
2026-06-08 11:17:03

 345

 7

#faiss #flink #python
Flink编程模型与API

Flink异步I/O机制通过并发处理外部系统请求，解决了同步访问导致的网络延迟瓶颈问题。它支持两种实现方式：使用Vert.x等原生异步客户端，或通过线程池模拟异步请求。关键特性包括：1）非阻塞查询，允许同时发送多个请求；2）资源高效，相比提高并行度更节省资源；3）提供超时处理机制确保稳定性。代码示例展示了如何通过Vert.x（Java/Scala）和线程池方式实现MySQL异步查询，包含连接管理、

Volunteer Technology
2026-06-04 22:23:05

 406

 10

#flink #大数据
Skill即服务：用Agent安全玩转云上Flink

Flink Skill 是阿里云为 AI Agent 时代设计的安全操作云上Flink的能力，解决了 Agent 直接调用 OpenAPI 操作生产环境时"能执行但不安全"的核心痛点。

阿里云大数据AI技术
2026-06-04 17:52:18

 406

 9

#阿里云 #人工智能 #flink
flink taskmanager 内存模型及内存调优案例

优先配置 Process Size‌：在 K8s/YARN 环境下，直接设置，让 Flink 自动计算内部各部分内存，避免手动配置冲突。‌预留安全余量‌：容器环境的内存限制应比略大（或依靠 Flink 自身的 Overhead 机制），防止因瞬时峰值被系统 Kill。‌监控驱动调优‌：利用 Flink Web UI 的 ‌Metrics‌ 标签页，重点关注以及。开启 GC 日志 ()，分析 GC

zhengxxm
2026-06-04 16:03:18

 414

 3

#flink #大数据
【持续更新中】开源贡献记录

但迟迟不review。3.13发邮件讨论FLIP-436，3.19投票，3.22投票通过，4.7终于合入了，跨度达到了两年多，终于完成了。目前：merged 2024.6.14 为了赶1.20 code freeze，半夜2点完成FLIP-436后，起来又发现CI失败了，排查是其他人刚提交的一个commit里的test有bug，很快修复了提了pr。切换到0.235版本后，同样的代码报错了，dele

码以致用
2024-07-30 10:28:23

 1165

 22

#大数据 #开源 #flink
Flink生产环境实战：从Demo到稳定运行的破局之道

Flink生产环境实践中的关键挑战与解决方案摘要：本文深入探讨了Flink在生产环境中的实际应用挑战，包括数据资产入口失控、CDC稳定性不足、SQL开发体验割裂、Paimon湖表治理困难等问题。针对这些痛点，提出了基于StreamPark的Awestream解决方案，通过统一Catalog管理、CDC平台化增强、交互式SQL开发环境、湖表治理工具链和三层稳定性保障机制，实现了从开发到生产的全链路

 Apache StreamPark
2026-05-28 10:08:46

 498

 12

#flink
Flink任务提交与架构模型（二）

FlinkOnYarn任务运行原理及提交模式分析摘要：本文详细介绍了Flink在Yarn集群上的运行机制，包括三种任务提交模式：Session会话模式、Per-Job单作业模式和Application应用模式。FlinkOnYarn通过客户端上传配置到HDFS，由ApplicationMaster管理资源分配，动态启动TaskManager。文章重点分析了Session模式的提交流程，包括资源动

 Volunteer Technology
2026-05-26 22:02:05

 472

 8

#flink #前端 #javascript
Flink任务提交与架构模型（一）

摘要：Flink任务提交支持三种模式：会话模式（Session Mode）、单作业模式（Per-Job Mode）和应用模式（Application Mode）。会话模式预先启动集群，所有作业共享资源；单作业模式为每个作业创建独立集群；应用模式为每个应用创建专属集群，优化客户端资源消耗。Standalone部署支持会话模式和应用模式，其中会话模式预先启动所有组件，应用模式则动态创建JobManag

Volunteer Technology
2026-05-26 21:44:24

 591

 17

#flink #架构 #大数据
Flink Forward Asia 2026 官宣深圳｜From Cloud Native to AI Native

2026年 Flink Forward Asia 首次来到深圳，以“实时数据，智能未来”为主题，诚邀全球开发者共赴这场实时数据与 AI 的思想盛宴！

阿里云大数据AI技术
2026-05-25 17:27:26

 597

 7

#人工智能 #flink #云原生
使用Debezium读取CDC事件并通过Flink任务写入Paimon表来构建实时数据管道的实践

本文详细介绍了构建端到端CDC数据管道的完整流程，涵盖PostgreSQL变更捕获、Kafka消息传输、Flink流处理及Paimon数据湖存储等关键环节。重点解析了CDC技术原理，包括基于日志的变更捕获方式、PostgreSQL逻辑复制机制（WAL、复制槽、pgoutput插件）以及Debezium的工作流程。同时对比了Kafka传统模式与KRaft模式的架构差异，并提供了单节点KRaft配置示

 zhaojiew10
2026-05-24 19:16:47

 693

 18

#flink #大数据
Paimon Lookup Join 详解

Paimon Lookup Join 是一种基于快照查询的维表关联方式，专为 Paimon 的 LSM 存储特性设计。它采用请求-响应模式，当主表数据到达时触发对维度表的点查询，返回维度表最新快照数据，而非实时关联。维度表需配置 merge-engine 为 deduplicate 或 partial-update，且 changelog-producer 必须设为 lookup。查询延迟取决于

 胖胖胖胖胖虎
2026-05-23 09:22:06

 495

 9

#flink
Skill即服务：用Agent安全玩转云上Flink

Flink Skill 是阿里云为 AI Agent 时代设计的安全操作云上Flink的能力，解决了 Agent 直接调用 OpenAPI 操作生产环境时"能执行但不安全"的核心痛点。Flink Skill 代表了云资源操作从"人工操控"到"AI 安全托管"的演进方向。A: Flink Skill 是阿里云为 AI Agent 设计的安全操作Flink的能力，将Flink专家运维经验固化为 Age

Apache Flink
2026-05-14 18:02:02

 2265

 14

#安全 #flink #人工智能 +1
Flink Forward Asia 2026 官宣深圳｜From Cloud Native to AI Native

在 Apache Flink 算子协同与开源生态上积极共建，依托 NVIDIA 在视频/图像编解码、图像处理与 GPU 模型推理上的加速能力，结合 Flink 的流式编排与窗口/状态管理，可帮助用户快速构建端到端、高性能、可扩展的多模态实时流处理架构，支撑 AI 解说、图文快讯、互动问答等丰富应用场景。延续 FFA 惯例，本次峰会所有议题均为开放征集而来，并由专业的议题评选委员会评分筛选，确保内容

 Apache Flink
2026-05-11 18:02:08

 1835

#人工智能 #flink #云原生 +1
Flink Agents 深度解读：当实时数据流遇上 AI 智能体

FlinkAgents是Apache Flink推出的新型事件驱动AI Agent框架，将流处理能力与AI Agent技术深度融合。不同于传统请求响应模式的Agent框架，它让Agent成为数据流上的算子，实现毫秒级实时处理、状态管理和容错保障。虽然目前处于0.x阶段，但凭借Flink成熟的流处理基础设施，FlinkAgents为AI与实时数据系统的深度整合提供了新范式，标志着AI技术正从应用层向

 码上滚雪球
2026-05-17 11:47:01

 1008

 17

#flink #人工智能 #大数据
Flink小计（二）-----Flink运行架构

目录一、Flink 运行时的组件二、任务提交流程三、任务调度原理四、思考4.1 并行度（Parallelism）4.2 TaskManager 和 Slots4.3 并行子任务的分配4.4 程序与数据流（DataFlow）4.5 执行图（ExecutionGraph）4.6 数据传输形式4.7 任务链（Operator Chains）一、Flink 运行时的组件作业管理器（JobManager）任

 words8
2021-09-04 13:26:58

 21

#flink #大数据 #hadoop
Flink内存管理机制：从 Task 到 NetworkBuffer

Flink内存机制深度解析与调优指南 Flink性能问题的根源往往在于内存配置不当而非资源不足。本文剖析了Flink1.20的内存模型架构，重点讲解了TaskManager内存的精细划分：包括框架堆内存、任务堆内存、托管内存、网络内存等核心区域。

码上滚雪球
2026-05-02 18:02:26

 598

 15

#flink #大数据
flink安装部署，写入paimon数据，Java读取数据

flink安装部署、flink-sql写入paimon数据、Java读取flink写入的paimon数据

 吴佳杰杰
2026-04-28 20:30:00

 357

 11

#flink #java #大数据
DSP平台滑膜观测器（SMO）无传感器PMSM电机控制代码功能说明

本项目是基于DSP平台（以TI DSP28335为核心）的无传感器永磁同步电机（PMSM）控制解决方案，采用滑膜观测器（SMO）实现转子位置与转速估算，启动阶段通过V/f控制策略保证平滑启动，同时提供完整的开源C代码与Matlab仿真模型，适用于电机控制领域的学习、研发与工程实践。项目包含244个代码文件，核心模块覆盖信号采集、坐标变换、PWM驱动、数学运算等关键环节，具备启动顺滑、控制精度高、可

 QQ:487739278
2026-04-22 14:45:00

 247

 6

#flink
Flink Agents 0.3 Roadmap 解读

Apache Flink Agents 是 Apache Flink 新晋子项目，专注构建事件驱动的流式 AI Agent。0.3 版本 roadmap 已公布：支持 Agent Skills 集成、Mem0 长期记忆、跨语言 Action/Events、Python 3.12、日志分级与可观测性增强等，目标打造生产级流式 Agent 框架。

Apache Flink
2026-04-09 20:03:35

 2682

 15

#flink #大数据
2026年国产数据同步工具对比评测：DataX、Canal、Flink CDC与FineDataLink深度横评

选择开源数据同步工具时，企业需正视以下典型痛点（这些是开源模式的结构性特征，而非产品本身的缺陷）：痛点维度具体表现影响需编码/脚本维护DataX需编写JSON配置，Flink CDC需Java开发，Canal需配置+Adapter开发人力成本高，依赖个人技术能力运维复杂无统一监控告警，故障排查依赖日志分析，高可用需自行搭建运维效率低，故障恢复时间长无统一管控多工具拼凑导致管道碎片化，任务状态无全局

 isNotNullX
2026-04-20 11:08:59

 725

 3

#flink #大数据
11套机械臂三维模型，三轴四轴五轴机械臂各种机械臂三维模型，

11套机械臂三维模型，三轴四轴五轴机械臂各种机械臂三维模型，三轴四轴五轴机械臂三维模型，sw打开，可编辑，可用于机械臂制作，机械臂打印。机械臂机械结构参考。

资深码侬
2026-04-15 10:45:00

 388

 2

#matlab #flink #r语言 +1
Paimon 与 ForSt 场景选型分析

本文对比了Paimon+小索引State与ForSt+全量Payload State两种架构选型。Paimon方案适用于低频批量访问场景，通过外部表存储payload实现状态轻量化，但需注意状态与数据分离带来的语义风险。ForSt方案适合高频热状态访问，保留Flink原生Exactly-Once语义。文章详细分析了Paimon的点查机制、状态分离风险及双Job架构实践，建议根据数据访问频率、复用需

 lifallen
2026-04-13 19:38:57

 423

 10

#flink #大数据 #java
流湖之变（一）：Kafka 正在被三个方向同时挑战

StreamNative 发布 Lakestream/UFK，进入公测。Kafka 正在被三个方向同时挑战：去掉它、改造它、装进云里。但真正的竞争不在管道速度，在谁能成为 AI 的默认数据底座。

科里 Coralyx
2026-04-13 18:42:58

 383

 10

#kafka #人工智能 #大数据 +1
风光储并离网切换仿真模型（下垂控制一次调频 +并离网切换切换）包含模型和三篇参考文献!

风光储并离网切换仿真模型（下垂控制一次调频+并离网切换切换）包含模型和三篇参考文献!

资深码侬
2026-04-12 18:00:35

 75

#汽车 #r语言 #开发语言 +2
船舶混合动力系统联合仿真模型 AMESim+Simulink 虚拟资料(双层模糊控制策略)

船舶混合动力系统联合仿真模型 AMESim+Simulink 虚拟资料(双层模糊控制策略)

资深码侬
2026-04-12 09:45:00

 355

 8

#matlab #flink
Flink Agents：Python 执行链路与跨语言 Actor (PyFlink Agent)

Flink Agents 框架实现了 Java 与 Python 的深度集成，使 Python 编写的 AI Agent 逻辑能够在 Flink Java 引擎上执行。AgentPlan 作为蓝图仅保存 Python 函数引用而非实现 JSON 序列化保留模块和函数名信息运行时通过解释器动态调用 Python 代码；基于 Flink 的 PythonEnvironmentManager 支持独

 lifallen
2026-04-11 11:40:27

 490

 10

#flink #人工智能 #大数据 +3
大数据毕设-基于Spark的粤港澳大湾区气象分析系统

本文介绍了基于Spark的粤港澳大湾区气象分析系统Mint的设计与实现。系统采用三台虚拟机搭建分布式Hadoop集群，集成Spark、Hive、Flink等大数据组件，构建了多源气象数据采集处理体系。通过实时和离线双通道采集气象数据，利用Spark进行批处理分析和LSTM等算法预测，最终通过Django实现数据可视化展示和AI智能解读。系统具备气象数据采集、处理、分析、预测及可视化功能，为粤港澳大

 Z0709D
2026-04-09 18:08:18

 527

 13

#大数据 #spark #hadoop +1
Flink 系列第5篇：Flink 窗口模型精讲（含实操代码）

本文详细解析Flink窗口模型，帮助开发者掌握无界数据流的分段统计技术。文章首先介绍窗口核心概念，包括时间窗口和计数窗口的分类及属性配置。随后重点讲解四种时间窗口（滚动、滑动、会话、全局窗口）的实现逻辑和应用场景，提供Scala/Java代码示例。最后解析计数窗口的API实现，通过元素个数触发统计。全文结合图示和实操代码，帮助读者深入理解窗口工作机制，解决数据丢失、重叠等常见问题，适用于Flink

juniperhan
2026-04-09 17:59:02

 712

 24

#flink #大数据 #数据仓库
Flink 系列第4篇：Flink 时间系统与 Timer 定时器实战精讲

本文深入解析 Flink 时间机制与 Timer 定时器的核心原理与应用。首先介绍 Flink 的两种时间类型（事件时间和处理时间），重点讲解事件时间的水印机制及其配置方法。随后详细拆解 Timer 的工作原理，包括注册、触发和执行流程，并通过订单超时监控的完整代码示例，展示如何结合 KeyedProcessFunction 和状态管理实现延迟触发业务逻辑。文章适用于 Flink 开发者，帮助掌握

 juniperhan
2026-04-08 11:01:00

 960

 25

#flink #java #大数据 +1
Flink 100道面试题库，跟着学一遍，足以掌握 90% 的核心考点

Flink 是一个开源的分布式流处理和批处理框架，核心设计理念是“批是流的特例”，认为所有数据处理本质上都是流式的，有界数据流只是无界数据流的一种特殊情况。Flink 以流为核心统一了批处理和流处理的 API 和执行引擎，实现了真正的流批一体。流处理具有低延迟、高吞吐的优势，能实现毫秒级延迟响应，非常适合实时数据分析和事件驱动应用场景。Operator Chain 是将多个算子合并到同一个 Tas

hyunbar
2026-04-08 08:27:25

 449

 8

#flink #面试 #大数据
Flink Agent：ActionTask 与可续跑状态机 (Coroutine/Continuation)

Flink Agent 的 ActionTask 机制通过协程/可续跑状态机设计，解决了用户代码中包含网络阻塞调用时的执行问题。核心思想是将同步代码自动拆分为可挂起、可恢复的任务片段：基础方案是强制用户使用回调，但会导致代码割裂和状态管理困难进阶方案引入 ActionTask 抽象，框架自动处理挂起/恢复：保存执行现场（continuation/awaitable）生成后续可调度任务（ge

lifallen
2026-04-06 15:02:22

 624

 9

#flink #大数据 #人工智能 +2
Flink Agent 与 Checkpoint：主循环闭环与 Mailbox 事件驱动模型

本文解析了Flink Agent中ActionExecutionOperator的核心处理机制，重点解决流式引擎中长耗时推理任务的并发与容错问题。文章通过演进式推导展示了从朴素循环实现到Mailbox事件驱动模型的优化过程：初始方案采用简单循环处理事件和动作，但会导致线程阻塞，影响并发和Checkpoint；引入Mailbox模型，通过任务分片和异步执行解决阻塞问题，允许主线程处理其他任务；

lifallen
2026-04-06 14:45:41

 895

 26

#flink #大数据 #人工智能 +3
线控转向系统动力学法 Carsim 和 Simulink 联合仿真模型探索

线控转向系统动力学法 Carsim和Simulink联合仿真模型Carsim是2020版本，Matlab是2019b版本1、一个基于横摆角速度增益不变的变传动比模块。2、包含Carsim完整数据库。3、系统建模方法是动力学法4、展示仿真结果图分别为角阶跃工况、双移线工况、汽车对应的响应曲线，并且与Carsim自带的机械转向对比图。

vRZOvtDOKWS
2026-04-03 16:45:00

 149

 1

#flink
基于Flink的实时大数据分析项目实战

随着企业数字化转型加速，实时数据处理需求呈指数级增长。Apache Flink作为业界领先的流处理框架，以其高吞吐量、低延迟、精确一次语义和灵活的窗口机制，成为实时大数据分析的首选工具。本文旨在通过真实项目案例，系统性讲解Flink的核心技术原理、架构设计及工程实践，帮助读者掌握从需求分析到系统落地的全链路开发能力。本文采用“原理解析→实战演示→应用扩展”的结构，依次讲解Flink的核心概念、算法

 weixin_51960949
2026-04-01 19:41:22

 321

 6

#flink #数据分析 #大数据
Flink源码阅读：Mailbox线程模型

下面我们来看 Mailbox 的具体实现，具体涉及到以下这些类。我们来逐个看一下这些类的定义和作用。本文我们梳理了 Mailbox 相关的源码。Flink 通过 Mailbox 线程模型来简化相关代码逻辑。

Ap0fMH91y
2026-03-31 17:05:53

 385

 7

#flink #java #jvm
探索锂枝晶生长过程的仿真之路：从Comsol到C

comsol仿真模型锂枝晶生长过程的枝晶生长Comsol仿真模型。锂枝晶生长过程的枝晶形貌，温度场耦合，应力场，浓度场，电势场。C++基于元胞自动机法模拟枝晶生长，能实现任意角度（偏心正方算法），同时采用LBM考虑了对流作用对枝晶生长的影响在电池研究领域，锂枝晶的生长一直是个关键问题。它不仅影响电池的性能，还可能带来安全隐患。今天咱就聊聊锂枝晶生长过程的仿真模型，从Comsol仿真模型到C++基于

 MhNHJesogA
2026-03-29 18:00:00

 155

 3

#flink
大数据领域Doris与Flink的实时数据处理协作

本文旨在全面解析Apache Doris与Apache Flink在实时数据处理场景下的协作机制，帮助读者理解如何将这两种技术有机结合，构建高性能、低延迟的实时数据分析系统。讨论范围涵盖从基础概念到高级应用的全栈知识。文章从技术背景入手，逐步深入到架构设计、实现细节和实战应用，最后展望未来发展趋势。每个章节都包含理论讲解和实际案例，确保读者能够获得全面的理解。：开源的MPP分析型数据库，支持实时数

 Java大师兄学大数据AI应用开发
2026-03-26 22:30:16

 331

 6

#大数据 #flink
智慧物业合同数字化系统：从洽谈场景切入的数智化落地实践

摘要：商业物业招商面临合同条款核算复杂、协同效率低等痛点。本文提出基于智能合同引擎+低代码平台+实时协同系统的数字化解决方案，通过动态规则建模（如Drools引擎）、移动端低代码表单和实时数据协同（企业微信集成），实现租金计算、减免期拆分等条款的秒级核算与多端同步。某物业企业应用后，条款调整耗时从15分钟缩短至2分钟，错误率降至0.3%，签约周期压缩50%。未来将结合AI推荐与物联网技术，进一步

 智慧物业老杨
2026-03-26 11:10:17

 510

 16

#flink #sqlite
实时数据质量监控：Kafka+Flink实战解决方案

在数字化转型时代，实时数据已成为企业决策的核心驱动力。然而数据采集过程中常出现缺失、格式错误、业务逻辑冲突等问题，导致下游分析失效。如何实现高吞吐量数据管道的低延迟质量监控？怎样定义可扩展的数据质量评估体系？如何将监控结果有效反馈到数据治理流程？核心概念：解析数据质量指标体系与技术栈选型逻辑架构设计：Kafka-Flink集成架构与数据流模型技术实现：从环境搭建到自定义质量校验算子开发量化评估：数

 数据结构与算法学习
2026-03-25 20:35:57

 353

 8

#kafka #flink #linq
相场变量模拟裂纹扩展：探索材料世界的微观奥秘

相场变量模拟裂纹扩展相场模型是一种数学模型，用于模拟和描述多相系统中相界面的演化。在材料科学中，相场方法被广泛应用于模拟材料内部的相变，包括晶体生长、相分离以及裂纹的产生和扩展等现象。相场模型在裂纹扩展的模拟中尤其有用，因为它能够自然地捕捉复杂的裂纹路径和裂纹分支现象。疲劳裂纹扩展：在循环载荷下的裂纹逐渐扩展在材料科学领域，理解和模拟材料内部的各种现象一直是研究的重点。其中，相场模型犹如一颗璀璨的

 UVhsSauK
2026-03-25 18:15:00

 266

 6

#flink
Flink 并行度变更时 RocksDB 状态迁移的关键机制与原理

Flink并行度变更时的状态迁移机制基于key group分片模型，将key空间映射到固定数量的key group，通过调整key group分配实现并行度变更。RocksDB按key group有序存储状态数据，使得扩容时只需分发对应的SST文件，缩容时合并多个SST文件。增量Checkpoint下需回溯完整的SST文件链。maxParallelism一旦设定不可更改，否则会导致恢复失败。Ope

zfqzfx
2026-03-25 13:29:36

 969

 27

#apache #flink #大数据