Flink DataStream Join CoGroup scala...
分类：
其他好文 时间：
2016-06-24 15:14:13
阅读次数：
547
这篇文章介绍Flink的分区器，在流进行转换操作后，Flink通过分区器来精确得控制数据流向。...
分类：
Web程序 时间：
2016-06-22 23:43:46
阅读次数：
424
这篇文章是对Flinkfault tolerance的一个总结。虽然还有些细节没有涉及到，但是基本的实现要点在这个系列中都已提及。回顾这个系列，每篇文章都至少涉及一个知识点。我们来挨个总结一下。...
分类：
Web程序 时间：
2016-06-21 07:07:32
阅读次数：
178
Flink DataStream EventTime...
分类：
Windows程序 时间：
2016-06-17 17:22:28
阅读次数：
1374
Flink 剖析 1.概述 在如今数据爆炸的时代，企业的数据量与日俱增，大数据产品层出不穷。今天给大家分享一款产品—— Apache Flink，目前，已是 Apache 顶级项目之一。那么，接下来，笔者为大家介绍Flink 的相关内容。 2.内容 2.1 What's Flink Apache F ...
分类：
Web程序 时间：
2016-06-14 10:09:43
阅读次数：
797
上一篇文章我们谈论了保存点的相关内容，其中就谈到了保存点状态的存储。这篇文章我们来探讨用户程序状态的存储，也是在之前的文章中多次提及的state backend(中文暂译为状态终端)。...
分类：
Web程序 时间：
2016-06-12 02:56:24
阅读次数：
243
应该会有不少人觉得我标题打错了，是不是想讲SparkStreaming或者Kafka+SparkStreaming啊？实际上这不是笔误，Kafka Streams是Kafka 0.10提供的新能力，用于实时处理Kafka中的数据流，和现有的流处理技术如SparkStreaming，Storm，Flink还是有些区别的。
1 概况
Kafka Streams是一套处理分析Ka...
分类：
其他好文 时间：
2016-06-10 12:31:17
阅读次数：
2810
上篇文章我们探讨了Zookeeper在Flink的fault tolerance中发挥的作用（存储/恢复已完成的检查点以及检查点编号生成器）。这篇文章会谈论一种特殊的检查点，Flink将之命名为——Savepoint(保存点)。...
分类：
Web程序 时间：
2016-06-04 20:57:13
阅读次数：
274
上一篇文章我们探讨了基于定时任务的周期性检查点触发机制以及基于Akka的actor模型的消息驱动协同机制。这篇文章我们将探讨Zookeeper在Flink的Fault Tolerance所起到的作用。其实，Flink引入Zookeeper的目的主要是让JobManager实现高可用（leader选举）。...
分类：
Web程序 时间：
2016-06-03 19:24:54
阅读次数：
286
继续Flink Fault Tolerance机制剖析。上一篇文章我们结合代码讲解了Flink中检查点是如何应用的（如何根据快照做失败恢复，以及检查点被应用的场景），这篇我们来谈谈检查点的触发机制以及基于Actor的消息驱动的协同机制。...
分类：
Web程序 时间：
2016-05-30 14:48:00
阅读次数：
243
