Flink 中定时加载外部数据

社区中有好几个同学问过这样的场景：　　 flink 任务中，source 进来的数据，需要连接数据库里面的字段，再做后面的处理 这里假设一个 ETL 的场景，输入数据包含两个字段 “type, userid....” ，需要根据 type，连接一张 mysql 的配置表，关联 type 对应的具体内容。相对于输入数据的数量，type 的值是很少的（这里默认只有10种）， 所以对应配置表就只有10条

>>阅读原文<<