前言 这是很多Flink用户不太注意的一个隐藏得比较深的坑（严格来讲不算bug），近期组内同学频繁踩坑，故十分有必要快速记录一下，以提请注意。 复现问题 用户意图：将有状态F...
发简信
IP属地：浙江
-
关于有状态Flink作业改变Kafka Consumer UID后位点跳变到EARLIEST这档事 -
本地部署DeepSeek R1与RAG简单实验前言 叠个甲，流水账，非专业，只是蹭一下DeepSeek的热度（ 实验环境为家用PC，配备NVidia GeForce RTX 4090D显卡、AMD锐龙9 9950X处理器...
-
「Transistor」又到了一年一度揭晓冠军单曲的时间~ 2024年的Top 1是来自著名二人组「Endorfin.」的「Transistor」[https://y.qq.com/n/ryqq/s...
-
Flink RocksDB状态缩放加速：RocksDB原生DeleteRange原理简析又见Rescale 笔者在很久之前的一篇文章（传送门[https://www.jianshu.com/p/f0a13f98dac2]）中讲解过Flink的状态缩放（Resca...
-
再谈Java类型擦除与其对Flink类型和序列化的影响前言 本文前半部分的内容在很久之前讲过，但是最近又有交接到团队内的历史任务出现这方面导致的性能问题，故有必要再讲一次，并扩展一部分新内容。先通过两个例子来引入Java类型擦除...
-
StarRocks Elasticsearch Catalog原理简析前言 Elasticsearch不仅是强大的全文搜索引擎，在很多场景下（特别是TiDB、ShardingSphere等框架成熟之前）也被当做分布式HTAP数据库使用，在存储、...
-
「渋谷アクアリウム」（涩谷水族馆）重操旧业。 2024年4月动画《夜晚的水母不会游泳》第5话插曲https://y.qq.com/n/ryqq/songDetail/498420410?songtype=0[...
-
浅谈SIMD、向量化处理及其在StarRocks中的应用前言 单指令流多数据流（SIMD）及其衍生出来的向量化处理技术已经有了相当的历史，并且也是高性能数据库、计算引擎、多媒体库等组件的标配利器。笔者在两年多前曾经做过一次有关该主...
-
聊聊存算分离StarRocks的垃圾清理机制前言 大家已经了解，StarRocks的更新模型、主键模型等在Flush和Compaction过程中会产生历史版本数据，这些垃圾数据需要及时被清理，以防止存储空间浪费。而St...