基於Flink實時數倉的完整鏈路

整理中 一，架構   二，整體流程 簡單的舉個案例： mysql binlog -->canal --> kafka -->Flink ods -->Flink dwd -->doris  中間有zeppelin可以提交Flink任務，執行腳本，查詢doris結果 調度器：apache dolphinscheduler（國產） 三，過程 實時數倉就是Flink+kafka，doris的作用是去重存

>>阅读原文<<