目录 1. 准备工作 生成数据 创建数据表 2. 创建数据表 创建数据源表 创建数据目标表 3. 计算 WITH子句 1. 准备工作 生成数据 source kafka json 数据格式 ： topic  case_kafka_mysql： {"ts": "20201011","id": 8,"price_amt":211} topic  flink_t