背景：在阿里云的Flink全托管一个flink作业 
链路是业务库RDS → kafka → Analysisdb Mysql 
建表为： 
– CREATE TABLE dw.dwi_oms_sku_price_newest 
– ( 
–     channel_sku          string 
–     ,unit_price          DECIMAL(20, 4) 
–     ,bi_last_update_time TIMESTAMP(3) 
–     ,currency            string 
–     ,db_name STRING,  – 读取库名。 
–     table_name STRING , – 读取表名。 
–     operation_ts TIMESTAMP(3), – 读取变更时间。 
–     op_type ...