要实现exactly-once语义 flink依赖checkpoint和可重放数据源（kafka） checkpoint 触发之后会在数据源插入产生checkpoint ba...
发简信
IP属地：四川
-
flink kafka 如何实现 exactly-once语义 -
Flink--Checkpoint机制原理基于flink-1.8.1 本文转载自一文搞懂Flink内部的Exactly Once和At Least Once 如何理解flink中state(状态) state泛指 s...
-
Spark、BulkLoad Hbase、单列、多列
背景 之前的博客：Spark：DataFrame写HFile （Hbase）一个列族、一个列扩展一个列族、多个列 用spark 1.6.0 和 hbase 1.2.0 版本实...
-
记一次redis性能优化前沿 最近工作中在优化redis访问性能，这里总结一下优化过程中redis使用方法的一些心得体会，以及在spring-data-redis开源项目提交代码的一些经验。具体来说...
-
mysql的日志文件
1错误日志文件 Error Log 记录mysql的运行过程中比较严重的警告和错误信息，默认是关闭状态，打开使用命令参数 -log-error 2二进制日志 Binary L...
