基于Flink SQL的实时处理架构

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

>>阅读原文<<