1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. F>
  5. flink sql

当前主题:flink sql

实时计算 Flink SQL 核心功能解密

实时计算 Flink SQL 核心功能解密 Flink SQL 是于2017年7月开始面向集团开放流计算服务的。虽然是一个非常年轻的产品,但是到双11期间已经支撑了数千个作业,在双11期间,Blink 作业的处理峰值达到了5+亿每秒,而其中仅 Flink S

阅读全文

Apache Flink SQL概览

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

阅读全文

深入分析 Flink SQL 工作机制

作者 | 伍翀(云邪),阿里巴巴技术专家 整理 | 陈婧敏(清樾),阿里巴巴技术专家 摘要:本文整理自 Flink Forward 2020 全球在线会议中文精华版,由 Apache Flink PMC 伍翀(云邪)分享,社区志愿者陈婧敏(清樾)整理。旨在帮

阅读全文

Flink SQL 1.11 新功能与最佳实践

作者:伍翀(云邪),Apache Flink PMC member,阿里巴巴技术专家整理:陈婧敏(清樾) 本文整理自 Apache Flink PMC,阿里巴巴技术专家伍翀(云邪)的分享,旨在帮助用户快速了解新版本 Table & SQL 在 Connect

阅读全文

Demo:基于 Flink SQL 构建流式应用

上周四在 Flink 中文社区钉钉群中直播分享了《Demo:基于 Flink SQL 构建流式应用》,直播内容偏向实战演示。这篇文章是对直播内容的一个总结,并且改善了部分内容,比如除 Flink 外其他组件全部采用 Docker Compose 安装,简化准

阅读全文

深入解读 Flink SQL 1.13

本文由社区志愿者陈政羽整理,Apache Flink 社区在 5 月份发布了 1.13 版本,带来了很多新的变化。文章整理自徐榜江(雪尽) 5 月 22 日在北京的 Flink Meetup 分享的《深入解读 Flink SQL 1.13》,内容包括: Fl

阅读全文

OPPO数据中台之基石:基于Flink SQL构建实数据仓库

作者 | 张俊 本文整理自 2019 年 4 月 13 日在深圳举行的 Flink Meetup 会议,分享嘉宾张俊,目前担任 OPPO 大数据平台研发负责人,也是 Apache Flink contributor。本文主要内容如下: OPPO 实时数仓的演

阅读全文

Flink SQL CDC 上线!我们总结了 13 条生产实践经验

01 项目背景 本人目前参与的项目属于公司里面数据密集、计算密集的一个重要项目,需要提供高效且准确的OLAP服务,提供灵活且实时的报表。业务数据存储在MySQL中,通过主从复制同步到报表库。作为集团级公司,数据增长多而且快,出现了多个千万级、亿级的大表。为了

阅读全文

flink sql相关问答

查看更多 提问题

Flink SQL相关问题

Flink SQL中的DATE_FORMAT()函数中,如何将bigint转换为timestamp类型?用cast转换失败,有大佬遇见这种问题么?

阅读全文

flink sql 从savepoint启动恢复程序状态

flink sql 从savepoint启动恢复程序状态,反序列化后,程序的数据有问题,flink sql写的程序如何从savepoint 启动

阅读全文

java能不能直接远程操作flink sql

转自钉钉群21789141:java能不能直接远程操作flink sql

阅读全文

flink sql 支持checkpoints吗?

使用flink sql进行实时计算(部署模式是on yarn)。想用到checkpoint,在flink-conf.yaml配置了: state.backend: filesystem state.checkpoints.dir: hdfs:///fl

阅读全文

Flink SQL中的DATE_FORMAT()函数中,如何将bigint转换为timestamp类型?

Flink SQL中的DATE_FORMAT()函数中,如何将bigint转换为timestamp类型?用cast转换失败,有大佬遇见这种问题么?

阅读全文

Flink SQL:在GROUP BY查询结果中重复分组键

我想在一个包含group by语句的表中在Flink SQL中进行简单查询。但是在结果中,group by语句中指定的列存在重复的行。那是因为我使用的是流媒体环境并且它不记得状态吗? final StreamExecutionEnvironment en

阅读全文

Flink SQL:用于连接表的内存不足

我经常更新MySql表。我想为过去20秒内更新的每个id拍摄快照,并将值写入redis。我使用binlog作为流输入,并将数据流转换为Flink表。我运行以下sql。 SELECT id, ts, val FROM my_tbl WHERE (id,

阅读全文