flink的一些学习笔记,将在github上持续更新
补充中……
${flink-web-url}/#/job-manager/config 的
web.tmpdir
配置相关
Note on IntelliJ: To make the applications run within IntelliJ IDEA, the Flink dependencies need to be declared in scope compile rather than provided. Otherwise IntelliJ will not add them to the classpath and the in-IDE execution will fail with a NoClassDefFountError. To avoid having to declare the dependency scope as compile (which is not recommended, see above), the above linked Java- and Scala project templates use a trick: They add a profile that selectively activates when the application is run in IntelliJ and only then promotes the dependencies to scope compile, without affecting the packaging of the JAR files.
<!--> ![Flink类型分类](./img/introduction-to-type-and-serialization-mechainisms-1.png)-->
flink程序使用启动参数时会用到
补充中……
Flink提供了两种在yarn上运行的模式,分别为Session-Cluster和Per-Job-Cluster模式,本文分析两种模式及启动流程。
flink内部收集指标: Counter 计数器、Gauge 一个值、Meter 统计吞吐量,单位时间内发生的次数、Histogram 统计数据分布,Max Min Mean
Flink HA & 恢复策略 &并发度 --待补充
Flink有什么办法解决由于Key partition造成的数据倾斜问题? ---待补充
Apache Flink极客挑战赛——Flink TPC-DS性能优化
补充中……
《追源索骥:透过源码看懂Flink核心框架的执行流程.pdf》
from github
《Introduction to Apache Flink》
英文版,100多页的小册子
补充中……
自己的一篇学习总结《数据同步工具Flinkx的研究与实践》
待测试
补充中……
补充中……
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。