Flink 的网络协议栈是组成 flink-runtime 模块的核心组件之一，是每个 Flink 作业的核心。它连接所有 TaskManager 的各个子任务，因此，对于 Flink 作业的性能包括吞吐与延迟都至关重要。与 TaskManager 和 J

本文由趣头条实时平台负责人席建刚分享趣头条实时平台的建设，整理者叶里君。文章将从平台的架构、Flink 现状，Flink 应用以及未来计划四部分分享。目前，基本已经把 Spark Streaming 和 Storm 淘汰了，主要都是 Flink SQL 来

在本文中，我们将从零开始，教您如何构建第一个Apache Flink 应用程序。开发环境准备Flink 可以运行在 Linux, Max OS X, 或者是 Windows 上。为了开发 Flink 应用程序，在本地机器上需要有 Java 8.x 和 ma

38、如何基于Flink+TensorFlow打造实时智能异常检测平台？只看这一篇就够了

32、为什么说流处理即未来？只看这一篇就够了。43、你公司到底需不需要引入实时计算引擎？

之前也分享了不少自己的文章，但是对于 Flink 来说，还是有不少新入门的朋友，这里给大家分享点 Flink 相关的资料，期望可以帮你更好的理解 Flink。这本书比较薄，简单介绍了 Flink，也有中文版，读完可以对 Flink 有个大概的了解。Driz

38、如何基于Flink+TensorFlow打造实时智能异常检测平台？只看这一篇就够了

本篇核心目标是让大家概要了解一个完整的Apache Flink SQL Job的组成部分，以及Apache Flink SQL所提供的核心算子的语义，最后会应用Tumble Window编写一个End-to-End的页面访问的统计示例。Apache Fli

本文来自2018年8月11日在北京举行的 Flink Meetup会议，分享来自于施晓罡，目前在阿里大数据团队部从事Blink方面的研发，现在主要负责Blink状态管理和容错相关技术的研发。流计算系统的任务和Hbase的数据存储有可能不在同一台机器上，导致

* The timeout in milliseconds for requesting a slot from Slot Pool.

* Constructor for a setup with purely local communication .

/** The collection of available memory segments. */

* JVM heap size for the JobManager with memory size.private static final String[] EMPTY = new String[0];* Get job manager's heap

* @param failureRate Maximum number of restarts in given interval {@code failureInterval} before failing a job

* Returns the type expected by this [[TableSink]].* This type should depend on the types returned by [[getFieldNames]].* @return

// returns the first 5 records from the sorted result. // skips the first 3 records and returns all following records from the s

.window // define over window with alias w. .select; // aggregate over the over window wOver Windows类似SQL的over子句，它可以基于

failValidation(s"Filter operator requires a boolean expression as input," +

tablePath.isEmpty, "tablePath must not be null or empty."). }scan方法内部调用的是scanInternal，scanInternal首先读取catalog及db信息，然后调

首先是有赞的实时平台架构。在这个部分，主要是 Flink 与 Spark 的 structured streaming 的一些对比和选择 Flink 的原因。第三个就是比较重点的内容，Flink 在有赞的实践。这其中包括了我们在使用 Flink 的过程中碰