概述

阿里云的flink技术文档特别喜欢挖坑。

最近看到[1]中提到了emit策略。

一通找，最后在[1]中发现当前的flink sql并不支持emit关键词

blink的源码就是flink的blink分支。统称flink,但是下面是分为flink(master)和blink两个分支

调研

git clone https://gitee.com/apache/flink

git checkout blink

flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/GroupWindowITCase.scala中可以看到:

   val sql ="""|INSERT INTO sink|SELECT|  string,|  TUMBLE_START(ts, INTERVAL '0.005' SECOND) as w_start,|  TUMBLE_END(ts, INTERVAL '0.005' SECOND),|  COUNT(DISTINCT `long`),|  COUNT(`int`),|  CAST(AVG(`int`) AS INT),|  weightAvgFun(`long`, `int`),|  MIN(`int`),|  MAX(`int`),|  SUM(`int`)|FROM T1|GROUP BY `string`, TUMBLE(ts, INTERVAL '0.005' SECOND)|EMIT WITHOUT DELAY AFTER WATERMARK""".stripMargin

編譯Blink

git clone https://gitee.com/apache/flink

git checkout blink

mvn clean -T 2C package -DskipTests

最后根据[4]可知，

阿里云的Blink集群其实根本是不对外开放的，只是个内部版本＋外部宣传文案

你們看下阿里自從blink第一個版本出來後，後續的blink3.7還有宣傳文案嗎？沒有

你們再看看阿里自從買下ververica以後，後續flink每次出來一個新版本，機會會鋪天蓋地的消息:新版本出來啦！

沒有宣傳文案，那麼這個東西就是不公開的。

Reference:

[1]emit策略

[2]flink1.12

[3]Blink源码编译

[4]blink編譯

flink sql是否支持emit策略相关推荐

Flink SQL Emit 输出策略
传送门:Flink 系统性学习笔记 Flink 1.13.5 假设现在遇到这样一个场景,我们需要实时统计每分钟.每小时甚至每天的 PV 或者 UV.如果使用 Flink SQL 中的滚动窗口来计算,那 ...
Flink SQL 核心解密 —— 提升吞吐的利器 MicroBatch
Flink SQL 核心解密 -- 提升吞吐的利器 MicroBatch 之前我们在 Flink SQL 中支持了 MiniBatch, 在支持高吞吐场景发挥了重要作用.今年我们在 Flink SQL ...
Flink最锋利的武器：Flink SQL入门和实战 | 附完整实现代码
作者 | 机智的王知无转载自大数据技术与架构(ID: import_bigdata) 一.Flink SQL 背景 Flink SQL 是 Flink 实时计算为简化计算模型,降低用户使用实时计算门 ...
KSQL和Flink SQL的比较
Confluent公司于2017年11月宣布KSQL进化到1.0版本,标志着KSQL已经可以被正式用于生产环境.自那时起,整个Kafka发展的重心都偏向于KSQL--这一点可以从Confluent官方 ...
Flink SQL 1.11 新功能与最佳实践
#2020云栖大会#阿里云海量offer来啦!投简历.赢阿里云限量礼品及阿里云ACA认证免费考试资格!>>> 整理者:陈婧敏(清樾) 本文整理自 Apache Flink PMC,阿 ...
【Flink】Flink 源码阅读笔记（15）- Flink SQL 整体执行框架
1.概述转载:Flink 源码阅读笔记(15)- Flink SQL 整体执行框架在数据处理领域,无论是实时数据处理还是离线数据处理,使用 SQL 简化开发将会是未来的整体发展趋势.尽管 SQL ...
基于数据库数据增量同步_基于 Flink SQL CDC 的实时数据同步方案
简介:Flink 1.11 引入了 Flink SQL CDC,CDC 能给我们数据和业务间能带来什么变化?本文由 Apache Flink PMC,阿里巴巴技术专家伍翀 (云邪)分享,内容将从传统的 ...
网易游戏 Flink SQL 平台化实践
摘要:本文整理自网易游戏资深开发工程师林小铂在 Flink Forward Asia 2021 平台建设专场的演讲.主要内容包括: 网易游戏 Flink SQL 发展历程基于模板 jar 的 Str ...
Flink 最锋利的武器：Flink SQL 入门和实战带你了解NBA球星数据
一.Flink SQL 背景 Flink SQL 是 Flink 实时计算为简化计算模型,降低用户使用实时计算门槛而设计的一套符合标准 SQL 语义的开发语言. 自 2015 年开始,阿里巴巴开始调研 ...

flink sql是否支持emit策略

概述

调研

編譯Blink

flink sql是否支持emit策略相关推荐

最新文章

热门文章