基于Flink SQL的实时处理架构

  本博文介绍基于Flink的多数据源->数据治理->Kafka->作业治理->DB的实时处理架构。数据治理，将读库降低为原来的2/3次，并使得多数据源转为统一Schema。基于统一的Schema数据流，作业治理将基于Jstorm的业务逻辑编码项目，简化成多条SQL语句的配置。   sar案例 可以先参阅 storm项目迁移flink案例：系统活动情况报告 而 Flink-sar-etl 流程我们

>>阅读原文<<