Flink Source耗尽判定机制详解 Flink Source耗尽判定机制详解 一、核心原理 Flink通过监控SourceFunction.run()方法是否返回来判定Source是否耗尽。 SourceFunction接口契约 public interface SourceFunction<T> extends Function, 2025-12-30 flink 3 yoxih
Watermark与allowedLateness详解 Watermark与allowedLateness详解 概述 在Flink流处理中，处理乱序数据需要两层机制： Watermark：决定何时触发窗口计算 allowedLateness：决定窗口触发后是否继续接受迟到数据 一、两者的关系 它们是两层不同的乱序容忍机制： 1. Watermark（第一 2025-12-30 flink 3 yoxih
Paimon Compaction 详解 Paimon Compaction 详解 总结 更新时间：2025-12-25 适用版本：Apache Paimon 1.3+（包含 0.8 vs 1.3 版本差异对比） 核心概念 Compaction 核心作用： 主键表：合并 LSM Tree 中的 Sorted Runs，防止查询性能下降和 O 2025-12-24 paimon 8 yoxih
Apache Paimon Partial-Update Apache Paimon Partial-Update 总结 更新时间：2025-12-12 本文档详细介绍 Paimon 的 partial-update 合并引擎和 sequence-group 机制 Sequence Group 核心规则： 配置了 sequence-group 的字段：只有 2025-12-12 paimon 10 yoxih
域名转发架构文档 域名转发架构文档 从公网到家庭服务的完整转发链路分析 目录 系统架构概览 域名层级结构 转发流程详解 服务配置矩阵 安全策略 性能优化策略 系统架构概览 整个系统采用双层 Nginx 反向代理架构，实现了从公网到家庭局域网服务的安全访问： 第一层：公网 VPS 上的 Nginx 2025-12-06 8 yoxih
Apache Paimon 表模式（Table Mode）详解 Apache Paimon 表模式（Table Mode）详解 总结 更新时间：2025-12-04 主要修改内容： 新增了 MOR 模式的详细读写机制说明 补充了 MOR 模式中 Compaction 触发时机的详细解释（区分 Flink 和 Spark） 明确了读取时的数据合并是内存计算而非物理 2025-12-04 paimon 11 yoxih
Paimon 表 Index 文件详解 Paimon 表 Index 文件详解 总结 更新时间：2025-12-04 主要修改内容： 修复了所有 SQL 示例中的 PRIMARY KEY (id) NOT ENFORCED 语法错误（Spark 不支持在列定义中声明主键） 为所有已测试的 SQL 语句添加了 ✅ 已测试 (Spark 3. 2025-12-04 paimon 8 yoxih
