Apache Paimon 是一个流批一体的数据湖存储格式，支持高吞吐的数据摄入和高效的实时/批量查询。Apache Gravitino 可以作为 Paimon 的统一元数据中心，通过。

目录一、事务二、@Transactional介绍三、@Transactional失效场景1、@Transactional 应用在非 public 修饰的方法上2、@Transactional 注解属性 propagation 设置错误3、@Transactional 注解属性 rollbackFor 设置错误4、同一个类中方法调用，导致@Transactional失效5、异常被你的 catch“吃

我们首先去官方网站下载Pycharm这款软件，找到我们需要下载2020.2.2版本，该软件有windows版本和mac版本，不管什么版本，安装都一样。下面是下载地址下载地址 https://www.jetbrains.com/pycharm/download/大家都懂的！下载链接：https://pan.baidu.com/s/1ILVUwAsFVlGxDOCKbj36pA提取码: sqnw解压之

SplitHDFS 的 InputSplitHive 的 SplitSpark 的 Partition分区信息Bucket ID一批数据文件删除文件（Deletion Files，如果启用了 Deletion Vectors）Split 是 Paimon 的读取单元，包含分区、Bucket、文件列表Split 大小可配置，通过调整（默认 128MB）⚠️ Split 数量受表类型影响主键表：通常

主键表受 Key Range 约束相同 Key Range 的文件必须在同一个 Split批处理并行度受限非主键表自由切分按文件大小 Bin Packing批处理并行度高。

主键表与非主键表配置速查指南 本文提供了主键表和非主键表的快速选择与配置参考。通过30秒决策流程图可快速确定表类型：需要更新/删除或有重复数据时选主键表，否则选非主键表。核心差异包括：主键表支持增删改操作但吞吐量较低(150-250MB/s)，非主键表仅支持插入但性能更高(400-600MB/s)。文中提供了详细的配置模板和参数推荐：主键表建议bucket数64-256，非主键表8-64即可。还包

Paimon Action Jar 采用 SPI 机制实现 Action 的动态加载与扩展。核心设计包括： 模块化架构：独立 action 模块避免类冲突，common 模块包含 Action 实现 SPI 服务发现：通过 META-INF/services 注册 ActionFactory，支持自定义扩展 双模式执行：LocalAction 本地执行轻量操作，普通 Action 构建 Flink

Paimon 表 Snapshot 过期流程摘要 Apache Paimon 的 Snapshot 过期机制通过自动和手动两种方式触发。自动触发发生在每次 Commit 后，通过 TableCommitImpl 类协调执行消费者过期、Snapshot 过期、分区过期和 Tag 操作。手动触发可通过 Flink SQL 或 Action 方式调用。 过期条件由四个核心参数控制：snapshot.nu

摘要 Apache Paimon 的 Compact 机制是流式数据湖存储系统的核心功能，主要用于优化文件管理、空间利用和查询性能。本文详细解析了其架构设计、触发机制和执行流程： 架构核心：包含 CompactManager、CompactStrategy 和 CompactTask 三大组件，分别负责管理、策略选择和执行合并任务 触发机制：支持内联Compact（写入时触发）、定时Compact

分布式锁的演进基本原理我们可以同时去一个地方“占坑”，如果占到，就执行逻辑。否则就必须等待，直到释放锁。“占坑”可以去redis，可以去数据库，可以去任何大家都能访问的地方。等待可以自旋的方式。阶段一public Map<String, List<Catalog2Vo>> getCatalogJsonDbWithRedisLock() {//阶段一Boolean lock