概述

阿里云的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策略的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。