在 Flink 1.10 的 Table API 和 SQL 中，表支持的格式有四種： 官網地址如下：https://ci.apache.org/projects/flink/flin ...

最近因為疫情的原因，偷了好長時間的懶，現在終於開始繼續看Flink 的SQL 了 ———————————————— 電腦上的Flink 項目早就升級到了 1.10了，最近還在看官網新的文檔，趁着 ...

　　Flink 統計當日的UV、PV 　　測試環境： 　　　　flink 1.7.2 　　1、數據流程 　　　　 　　　　a.模擬數據生成，發送到kafka（json 格式）　　 　　　　 ...

Flink 1.11 發布了支持 MySQL CDC（Changelog Data Capture） 可以直接解析 Canal / Debezium 格式的 MySQL Binlog 對於實時處理程 ...

Flink 1.11 版本對SQL的優化是很多的，其中最重要的一點就是 hive 功能的完善，不再只是作為持久化的 Catalog，而是可以用原生的 Flink SQL 流式的寫數據到入 hive中 ...

　　接上篇：【翻譯】Flink 異步I / O訪問外部數據 　　最近看了大佬的博客，突然想起Async I/O方式是Blink 推給社區的一大重要功能，可以使用異步的方式獲取外部數據，想着自己實現以 ...

社區中有好幾個同學問過這樣的場景：　　 這里假設一個 ETL 的場景，輸入數據包含兩個字段 “type, userid....” ，需要根據 type，連接一張 mysql 的配置表， ...

接上篇：Flink FileSink 自定義輸出路徑——BucketingSink 上篇使用BucketingSink 實現了自定義輸出路徑，現在來看看 StreamingFileSink( 據說 ...

先上代碼： 直接上報錯信息： 報錯信息是找不到合適的table factory，查詢報錯類TableFactoryService.scala 源碼214行（ ...

參考： 官網協議介紹：http://kafka.apache.org/protocol.html#The_Messages_Fetch kafka協議兼容性 http://www.cnblogs ...