概述

阿里云的flink技術(shù)文檔特別喜歡挖坑。

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

一通找，最后在[1]中發(fā)現(xiàn)當(dāng)前的flink sql并不支持emit關(guān)鍵詞

blink的源碼就是flink的blink分支。統(tǒng)稱flink,但是下面是分為flink(master)和blink兩個分支

調(diào)研

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?

最后根據(jù)[4]可知，

阿里云的Blink集群其實(shí)根本是不對外開放的，只是個內(nèi)部版本＋外部宣傳文案

?

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

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

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

?

?

?

?

Reference:

[1]emit策略

[2]flink1.12

[3]Blink源碼編譯

[4]blink編譯

總結(jié)

以上是生活随笔為你收集整理的flink sql是否支持emit策略的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。