通过connector的方式定义数据: 数据类型定义为:yldrate DECIMAL, pf__id VARCHAR(10), symbol_id VARCHAR(30) 数据库中yldrate数据前几条是这样的: 0.000072101337 0.000000000000 0.000000000000 0.000212493881 0.000078719845 0.000073023505 0.000070173309 0.000070168385 但是,pyflink读取出来转为pandas后都是: yldrate 0 0 1 0 2 0 3 0 4 0 5 0 不知道是什么原因,导致精度损失,我要如何设置,使数据能够无损失读取?小白在线蹲大佬回复~拜托啦!
- pyflink1.11 从Mysql读取Decimal类型数据,数据精度损失问题 肖越