CDH6.3.2 Cloudera Manager 集成Flink1.12.0
由於項目需要，需要用到flink cdc進行Flink SQL 開發，一起增加開發效率，減少很多java代碼開發. 在版本方面，Flink CDC 在flink1.11 以上的版本才有支持，在這里選擇Flink1.12.0。 CDH版本：CDH6.3.2 Cloudera Manager 集成 ...
相關推薦
編譯 flink 1.12.0
://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.12.0/flink-1.12.0-sr ...
【翻譯】Apache Flink 1.12.0 Release Announcement
本文來自官網： https://flink.apache.org/news/2020/12/10/release-1.12.0.html 2020年12月10日Marta Paes（@morsapaes）和Aljoscha Krettek（@aljoscha） Apache Flink社區很高 ...
Flink 1.12.0 sql 任務指定 job name
參考前文：解決 Flink 1.11.0 sql 不能指定 jobName 的問題 從 FLink 1.11 改版 sql 的執行流程后，就不能和 Stream Api 一樣使用 env.execute("JobName") 來指定任務名 看了源碼后發現，在 sql 任務中，直接使用 ...
flink-1.12.0 upsert-kafka connector demo
參考官網： https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/kafka.htmlhttps://ci.apache.org/projects/flink ...
Apache Flink 1.12.0 正式發布，DataSet API 將被棄用，真正的流批一體
Apache Flink 1.12.0 正式發布 Apache Flink 社區很榮幸地宣布 Flink 1.12.0 版本正式發布！近 300 位貢獻者參與了 Flink 1.12.0 的開發，提交了超過 1000 多個修復或優化。這些修改極大地提高了 Flink 的可用性，並且簡化（且統一 ...
flink如何動態支持依賴jar包提交
通常我們在編寫一個flink的作業的時候，肯定會有依賴的jar包。flink官方希望你將所有的依賴和業務邏輯打成一個fat jar，這樣方便提交，因為flink認為你應該對自己的業務邏輯做好單元測試，而不應該把這部分測試工作頻繁提交到集群去做。但事實是我們往往不願意打一個fat jar ...
flink如何動態支持依賴jar包提交
通常我們在編寫一個flink的作業的時候，肯定會有依賴的jar包。flink官方希望你將所有的依賴和業務邏輯打成一個fat jar，這樣方便提交，因為flink認為你應該對自己的業務邏輯做好單元測試，而不應該把這部分測試工作頻繁提交到集群去做。但事實是我們往往不願意打一個fat jar，我們希望 ...