@Jianzhi Zhang
嗯，是这个原因，感谢 回复。 就是decimal的精度问题
在 2020-12-01 13:24:23，"Jianzhi Zhang" 写道：
>是不是你的decimal字段长度太短了，计算结果超出了精度范围导致null的出现
>
>> 2020年11月19日 下午10:41，kandy.wang 写道：
>>
>> --mysql表
>> CREATE TABLE IF NOT EXISTS `mysql_realtime_leaving_price_spu_index_agg`(
>> `id` INT
hi Jark：
打了一下log 看了一下聚合相关的几个字段： v_spu_id 、leaving_num 、price
都没有出现NULL的情况，在sql-client里看了一下也没有出现NULL的情况
自定义的format逻辑和canal的类似，insert update delete ,update 消息是需要发送2条 update_before
update_after，format逻辑是应该这么写的吧。
在 2020-11-19 23:13:19，"Jark Wu" 写道：
>你可以先直接 select * from hive.database.table;
hi Jark：
打了一下log 看了一下聚合相关的几个字段： v_spu_id 、leaving_num 、price
都没有出现NULL的情况，在sql-client里看了一下也没有出现NULL的情况
自定义的format逻辑和canal的类似，insert update delete ,update 消息是需要发送2条 update_before
update_after，format逻辑是应该这么写的吧。
在 2020-11-19 23:13:19，"Jark Wu" 写道：
>你可以先直接 select * from hive.database.table;
