文章 2020-09-16 来自:开发者社区

重新定义性能测试: Apache Flink 重磅开源流计算基准测试框架

01 背景 随着数据时效性对企业的精细化运营越来越重要,“实时即未来”、“实时数仓”、“数据湖” 成为了近几年炙手可热的词。流计算领域的格局也在这几年发生了巨大的变化,Apache Flink 在流批一体的方向上不断深耕,Apache Spark 的近实时处理有着一定的受众,Apache Kafka 也有了 ksqlDB 高调地进军流计算,而 Apache Storm 却开始逐渐地退出历史的舞台....

重新定义性能测试: Apache Flink 重磅开源流计算基准测试框架
问答 2020-07-06 来自:开发者社区

我用 yarn session 提交的 flink 任务 流计算消费 kafka #Flink

我用 yarn session 提交的 flink 任务 流计算消费 kafka , 为什么会 finished ? #Flink

问答 2020-05-28 来自:开发者社区

FlinkSQL处理流计算,我想要统计一天的总和,并且10分钟输出一次。用Dat #Flink

FlinkSQL处理流计算,我想要统计一天的总和,并且10分钟输出一次。用DataStream API有trigger,请问SQL是怎么实现呢。大佬们提点一下?#Flink

问答 2019-12-16 来自:开发者社区

flink 一个流计算多个任务和 还是一个流一个任务好?

flink 一个流计算多个任务和 还是一个流一个任务好? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

文章 2019-04-29 来自:开发者社区

流计算框架 Flink 与 Storm 的性能对比

(备注:原文链接https://mp.weixin.qq.com/s/b8Jiqj_SXM1acckTPyv57g) 作者:孙梦瑶 概述: 将分布式实时计算框架 Flink 与 Storm 进行性能对比,为实时计算平台和业务提供数据参考。 1. 背景 Apache Flink 和 Apache Storm 是当前业界广泛使用的两个分布式实时计算框架。其中 Apache Storm(以下简称“St....

文章 2019-01-05 来自:开发者社区

Apache Flink,流计算?不仅仅是流计算!

作者:王峰(花名:莫问) 2018年12月下旬,由阿里巴巴集团主办的Flink Forward China在北京国家会议中心举行。Flink Forward是由Apache软件基金会授权的全球范围内的Flink技术大会,2015年开始在德国柏林举办,今年第一次进入中国。 今天,计算平台事业部的资深技术专家莫问,将带领我们重温这场大数据技术的饕餮盛宴,感受Apache Flink 作为下一代大数据....

Apache Flink,流计算?不仅仅是流计算!
文章 2018-11-14 来自:开发者社区

容错和高性能如何兼得: Flink创始人谈流计算核心架构演化和现状

前言# 当前,流数据平台的普及率正在飙升。为了解决日益增长的实时数据处理需求,一些公司正在将其部分大数据基础架构转换为流式处理模型。 基于流数据的基础架构不仅能够更好地解决延迟敏感的数据处理业务需求,同时提供更多深入业务洞察 ; 另外,流式数据处理平台让传统的数据仓库建设更加简单灵活。 流式基础架构的关键部分是流计算引擎。优秀的流式计算引擎可以让业务即使在有状态计算的情况下,也能提供低延迟、高.....

问答 2018-07-30 来自:开发者社区

阿里云流计算 Flink SQL 核心功能解密

阿里云技术专家 伍翀(云邪)在2017云栖大会·北京峰会中做了题为《阿里云流计算 Flink SQL 核心功能解密》的分享,就Flink 2SQL 解密,StreamCompute 3 2.0 平台,应用案例等方面的内容做了深入的分析。 https://yq.aliyun.com/download/2390?spm=a2c4e.11154804.0.0.21146a79RmZcI5

文章 2018-02-08 来自:开发者社区

Flink SQL 功能解密系列 —— 阿里云流计算/Blink支持的connectors

Blink Connectors 总览 Connector 是连接外部数据和blink计算框架的桥梁,也是流计算的入口和出口。目前,blink支持了集团内部绝大多数的上下游(如下图),详细的接入方法可以见官方文档,本文主要阐述connector设计和使用上需要注意的问题。 Source插件 1. source connector控制消费位点 blink读取上游数据时,会记录消费位点和控制消...

文章 2018-02-08 来自:开发者社区

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

什么是retraction(撤回) 通俗讲retract就是传统数据里面的更新操作,也就是说retract是流式计算场景下对数据更新的处理 方式。 首先来看下流场景下的一个词频统计列子。 没有retract会导致最终结果不正确↑: retract发挥的作用 下面再分享两个双十一期间retract保证数据正确性的业务case: case1: 菜鸟物流订单统计 同一个订单的商品在运输过程中,因...

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注