|
目录
一.简介
二.Flink API 详解
三.Flink 常用 Demo 案例
四.Flink 线上开发异常解决与分析
五.心路历程
一.简介
Flink 成长之路是博主在接触并开发公司?Flink 线上项目后，从 API + 实战角度按顺序总结的专栏，Flink 版本适配 1.13.x、Scala 版本适配 2.11.x、2.12.x，其中大部分章节和 Demo 主要基于 Flink + Scala 的组合实现，少部分章节内容也涉及到 Java 的开发，其中很多内容都是在千万级别用户、十亿级别流量场景实战总结而来。?主要分为3个部分：
- Flink API 详解
- Flink 常用 Demo 案例
- Flink 线上开发异常解决与分析
后续也会继续基于开发场景总结更新这三部分内容 ...
二.Flink API 详解
基于官方 API 翻译并扩展，增加使用 Demo。
三.Flink 常用 Demo 案例
线上开发以及基础项目实现 Demo 与调优。
四.Flink 线上开发异常解决与分析
本地测试与线上运行遇到的异常与分析排查解决。
五.心路历程
想着 20 年第一次接手离职同事的 Flink 项目，当时是还是用 Flink 1.8?+ Java 开发，不断学习了一年多，22年正好有新的项目需求和 Flink 十分匹配，也借此机会把? Flink 的一些基础知识相对系统的过了一遍，由于自己开发 Scala 居多，所以还需要把 java 相关语言都转换到 Scala，同时新项目大概从 3 月迭代到 9月，期间也是不断增加需求，不断线上出错最终也是不断踩坑不断调整，终于达到了现在高并发高可用的状态。通过不断更迭项目也对 Flink 有了新的认识，再重新回看很多当年觉得晦涩难懂的概念，有一种恍然大悟的感觉。最明显的就是对 WaterMark 水位线的理解，记得最早接触这个概念在 CSDN 搜了一篇大佬的博客，看了好几遍也没明白所以然，好在后来没有放弃，看书看博客写代码测试，总算是搞明白一点。?不管怎样，坚持一定会有收获，加油吧 ！💪
|