# 实时计算 Flink版 #
1
关注
33666内容
|
Windows环境下Flink消费Kafka实现热词统计
前言碎语
昨天博主写了《windows环境下flink入门demo实例》实现了官方提供的最简单的单词计数功能，今天升级下，将数据源从socket流换成生产级的消息队列kafka来完成一样的单词计数功能。
|
【阿里云新品发布·周刊】第10期：阿里云DCDN自主研发的IP应用加速，为加速而生！
2019年5月22日15时，阿里云DCDN - IP应用加速是阿里云自主研发的一款更高效、更安全、更便捷的动态加速产品，结合阿里云CDN本身的资源优势，利用就近接入、智能路由，传输协议优化以及多种负载均衡技术，实现更高可靠的全站加速解决方案。
|
Flink在唯品会的实践
> 本文来自于王新春在2018年7月29日 Flink China社区线下 Meetup·上海站的分享。王新春目前在唯品会负责实时平台相关内容，主要包括实时计算框架和提供实时基础数据，以及机器学习平台的工作。之前在美团点评，也是负责大数据平台工作。他已经在大数据实时处理方向积累了丰富的工作经验。
本文主要内容主要包括以下几个方面：
1. 唯品会实时平台现状
2. Flink在唯
|
Flink最佳实践（一）流式计算系统概述
前言
传统的批处理拥有巨大 吞吐量 的优势，但是随之而来的是极其 高延迟 的缺陷。
随着大数据系统的不断发展，传统的批处理已然无法全部满足对 时效性 要求愈加严苛的业务需求。
为了适应逐渐变得 「实时」 的年代，大数据系统架构也由简单的批处理转向批流混合的Lambda架构，最后可能会逐渐演变成只有流计算的 高精准高时效 的Kappa架构。
|
2018杭州云栖大会参会总结
数字化、在线化、智能化驱动数字中国
=============
本次云栖大会的主题是驱动数字中国，以阿里集团和阿里云的先进技术帮助中国更多的中小企业实现数字化转型，或者更好的利用数据、
修改代码150万行！与 Blink 合并后的 Apache Flink 1.9.0 究竟有哪些重大变更？
早在今年1月，阿里便宣布将内部过去几年打磨的大数据处理引擎 Blink 进行开源并向 Apache Flink 贡献代码。Flink 1.9.0 版本在结构上有重大变更，修改代码达 150 万行，本文将梳理 Flink 1.9.0 中非常值得关注的重大变更与新增功能特性。
|
Flink Broadcast State实用指南
从1.5.0开始，Flink提供了一种新的State类型，称为Broadcast State。在这篇文章中，我们将解释什么是Broadcast State，并展示如何将其应用于评估事件流上的动态模式的应用的示例。
|
Flink常见异常和错误信息小结
Flink的常见异常众多，不可能面面俱到，所以想到哪儿写到哪儿，有漏掉的之后再补充。部署和资源问题(0) JDK版本过低这不是个显式错误，但是JDK版本过低很有可能会导致Flink作业出现各种莫名其妙的问题，因此在生产环境中建议采用JDK 8的较高update（我们使用的是181）。
免费试用