原创2020-09-11 flink12 分钟 读完 (大约 1872 个字)浅谈Flink的checkPoint机制为了保证state的容错性,Flink需要对state进程checkPoint,Checkpoint是Flink实现容错机制最核心的功能。 大数据flink 阅读更多>>
原创2020-09-09 flink15 分钟 读完 (大约 2292 个字)浅谈flink state状态管理机制Apache Flink®—Stateful Computations over Data Streams,flink是一个默认就有状态的分分析引擎,针对流失计算引擎中的数据往往是转瞬即逝,但在flink真实业务场景确不能这样,什么都不能留下,肯定是需要有数据留下的,针对这些数据留下来存储下来,在flink中叫做state,中文可以翻译成状态。 大数据flink 最后修改: 2020-09-09 阅读更多>>
原创2020-08-30 flink13 分钟 读完 (大约 1926 个字)Flink 如何自定义mysql source与sink,实现mysql的读取和写入Flink 如何自定义mysql source与sink,实现mysql的读取和写入 大数据flink 最后修改: 2020-08-30 阅读更多>>