pyflink1.11 从Mysql读取Decimal类型数据，数据精度损失问题

[肖越]

通过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  
不知道是什么原因，导致精度损失，我要如何设置，使数据能够无损失读取？小白在线蹲大佬回复~拜托啦！

[肖越]

问题已解决 ~ 数据定义的问题
















在 2020-12-30 13:41:16，"肖越" <[hidden email]> 写道：

通过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  
不知道是什么原因，导致精度损失，我要如何设置，使数据能够无损失读取？小白在线蹲大佬回复~拜托啦！