基於Flink SQL的實時處理架構

  本博文介紹基於Flink的多數據源->數據治理->Kafka->做業治理->DB的實時處理架構。數據治理，將讀庫下降爲原來的2/3次，並使得多數據源轉爲統一Schema。基於統一的Schema數據流，做業治理將基於Jstorm的業務邏輯編碼項目，簡化成多條SQL語句的配置。html   sar案例 能夠先參閱 storm項目遷移flink案例：系統活動狀況報告sql 而 Flink-sar-e

>>阅读原文<<