IP属地：上海
-
深入解析 Flink 细粒度资源管理细粒度资源管理的背景 目的 Flink 目前采用粗粒度的资源管理方法，其中task被部署到预定义的、通常相同的slot中，而不需要每个包含多少资...
-
MySQL备份和恢复类型
备份和恢复类型 物理（原始）与逻辑备份 物理备份由存储数据库内容的目录和文件的原始副本组成。这种类型的备份适用于出现问题时需要快速恢复的大型重要...
-
Flink整合面向用户的数据流SDKs/API(Flink关于弃用Dataset API的论述)
动机 Flink提供了三种主要的sdk/API来编写程序:Table API/SQL、DataStream API和DataSet API。我们...
-
Flink JobManager | TaskManager内存模型Flink内存模型分析 JobManager内存模型 TaskManager内存模型 内存模型分析 Flink使用内存（Total Flink ...
-
Flink使用Pod Template将状态快照(Checkpoint、Savepoint)存储在NFS
背景 Flink 版本 1.13.3，使用 native k8s[https://mp.weixin.qq.com/s/QE_37OrPVdRb...
-
Flink中如何实现一个自定义MetricReporter
什么是 Metrics 在 flink 任务运行的过程中，用户通常想知道任务运行的一些基本指标，比如吞吐量、内存和 cpu 使用情况、check...
-
flink+kafka的端到端一致性
上一篇中提到flink+kafka如何做到任务级顺序保证，而端到端一致性即为实现用户数据目标端与源端的准确一致，当源端数据发生更改时，保证目标端...
-
flink+kafka的端到端一致性上一篇中提到flink+kafka如何做到任务级顺序保证，而端到端一致性即为实现用户数据目标端与源端的准确一致，当源端数据发生更改时，保证目标端...
-
静态方法单元测试
将mockito-core换成mockito-inline 先创建一个调用了静态方法的待测试类 创建单元测试类 打印结果 测试通过，打印的日期是...