超凡 Blog

Follow your instincts and do what you think is right!

Flink 消费 Kafka

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

做实时任务时，Kafka 负责把数据送进来，Flink 负责按业务时间做窗口、去重、关联。业务时间一沾边，就绕不开三件事：事件时间、水位线、迟到数据。网上概念文章很多，真正卡在生产里的，往往是参数怎么设、乱序怎么扛、迟到了要不要补。这篇文章按落地顺序讲：为什么要用事件时间，水位线怎么配，乱序和迟到分别怎么处理，以及几个容易踩的坑。为什么不能只用处理时间处理时间简单：算子拿到数据的...

Posted by shichaofaan on May 14, 2025

Doris

varchar与bigint兼容性测试

关于varchar和bigint在Doris中做为连接字段兼容性分析测试 bigint数值范围：bigint类型可以存储的数值范围是-263到263-1，所以大小应该在下面范围之内-9,223,372,036,854,775,808到9,223,372,036,854,775,807，19位数字。bigint（x），x与显示宽度有关。 varchar数值...

Posted by shichaofaan on March 18, 2025

My First Post

Hello World, Hello Blog

Hey >这是我的第一篇博客。嗨，大家好！欢迎来到我在 GitHub 搭建的技术博客。在这里，我将记录自己在技术学习、项目实践过程中的点点滴滴，分享心得、经验以及遇到的问题与解决方案。希望这个博客不仅能成为我个人知识沉淀的地方，也能为广大技术爱好者提供一些有价值的参考和交流的平台。 >最后附上GitHub：https://github.com/shichaofaan

Posted by Shichaofaan on March 17, 2025