基於Flink SQL的實時處理架構

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

>>阅读原文<<