Tags

keep hungry keep foolish
生活

My First Post

Hello World, Hello Blog

Doris

Doris

varchar与bigint兼容性测试

test测试

Doris

varchar与bigint兼容性测试

Flink

Paimon 与 Flink / Spark 提交语义

两阶段提交、checkpoint 与 snapshot，以及 failover 后的重复写

Agent 与数据运维

用在排障和日常操作上的几个真实场景

Flink CDC 与 binlog

一次 MySQL binlog 文件块损坏的故障复盘

Flink 背压

一次订单宽表任务的排查与治理

Flink 消费 Kafka

水位线、乱序与迟到数据怎么落地

Kafka

Kafka 消费一致性

重复消费、丢数和「看起来对不上」

Flink 消费 Kafka

水位线、乱序与迟到数据怎么落地

实时计算

Kafka 消费一致性

重复消费、丢数和「看起来对不上」

Flink 背压

一次订单宽表任务的排查与治理

Flink 消费 Kafka

水位线、乱序与迟到数据怎么落地

性能排查

Flink 背压

一次订单宽表任务的排查与治理

一致性

Kafka 消费一致性

重复消费、丢数和「看起来对不上」

Flink CDC

Flink CDC 与 binlog

一次 MySQL binlog 文件块损坏的故障复盘

MySQL

Flink CDC 与 binlog

一次 MySQL binlog 文件块损坏的故障复盘

Agent

Agent 与数据运维

用在排障和日常操作上的几个真实场景

数据运维

Agent 与数据运维

用在排障和日常操作上的几个真实场景

Spark

Paimon 与 Flink / Spark 提交语义

两阶段提交、checkpoint 与 snapshot，以及 failover 后的重复写

Spark 数据倾斜

批处理里一次 join 倾斜的定位与处理

数据倾斜

Spark 数据倾斜

批处理里一次 join 倾斜的定位与处理

批处理

Spark 数据倾斜

批处理里一次 join 倾斜的定位与处理

Paimon

Paimon 与 Flink / Spark 提交语义

两阶段提交、checkpoint 与 snapshot，以及 failover 后的重复写

Paimon Bucket、分区与文件布局

bucket-key、动态桶、裁剪与热点店铺倾斜

Paimon 读写路径与并发控制

Snapshot isolation、commit 冲突与重试怎么落到源码路径

Paimon 主键表 LSM 与合并机制

changelog-producer、compaction 与 sequence 裁决

Paimon 整体架构与表格式设计

Snapshot、Manifest 与 Data File 怎么串起来

湖仓

Paimon 整体架构与表格式设计

Snapshot、Manifest 与 Data File 怎么串起来

架构

Paimon 整体架构与表格式设计

Snapshot、Manifest 与 Data File 怎么串起来

LSM

Paimon 主键表 LSM 与合并机制

changelog-producer、compaction 与 sequence 裁决

Compaction

Paimon 主键表 LSM 与合并机制

changelog-producer、compaction 与 sequence 裁决

并发

Paimon 读写路径与并发控制

Snapshot isolation、commit 冲突与重试怎么落到源码路径

事务

Paimon 读写路径与并发控制

Snapshot isolation、commit 冲突与重试怎么落到源码路径

Bucket

Paimon Bucket、分区与文件布局

bucket-key、动态桶、裁剪与热点店铺倾斜

分区

Paimon Bucket、分区与文件布局

bucket-key、动态桶、裁剪与热点店铺倾斜

Exactly-Once

Paimon 与 Flink / Spark 提交语义

两阶段提交、checkpoint 与 snapshot，以及 failover 后的重复写