Flink 中定時加載外部數據

社區中有好幾個同學問過這樣的場景：　　 flink 任務中，source 進來的數據，需要連接數據庫裏面的字段，再做後面的處理 這裏假設一個 ETL 的場景，輸入數據包含兩個字段 「type, userid....」 ，需要根據 type，連接一張 mysql 的配置表，關聯 type 對應的具體內容。相對於輸入數據的數量，type 的值是很少的（這裏默認只有10種）， 所以對應配置表就只有10條

>>阅读原文<<