flink流處理訪問mysql

業務場景以下： java     概述：採集工廠設備的數據。mysql     flink鏈接emqtt消息隊列， 流處理數據， 設備數據json內沒有設備的machID， 須要從mysq根據gateMac獲取對應的machID， 而且須要5分鐘獲取從mysql獲取一次， 定時刷新，redis    若是flink項目只是在初始化的時候獲取一次，那麼平臺新建一個設備， flink項目須要重啓一次，

>>阅读原文<<