数据清洗吧，还有一些实时的统计指标。
虽然clickhouse有直接接kafka的功能，但是我试过，
一旦遇到字段不符合定义，直接退出。
所以还需要整一个etl。不知道最新版的改进了没有。

【 在 MyWorkLife (我是谁) 的大作中提到: 】
: 用flink的目的是啥呢，
: clickhouse的查询还不够满足实时性？
--
FROM 223.104.96.*