flink1.11.0读取mysql数据decimal类型会强转成decimal(38,18)的问题

Tue, 14 Jul 2020 03:00:37 -0700 

hi，all：
现在遇到一个问题，通过sql-client读取mysql数据时，decimal类型会强转成decimal(38,18)
mysql ddl：
CREATE TABLE `test2` (
  `money` decimal(10,2) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;


insert into test2 values(10.22);


flink ddl：
CREATE TABLE test2 (
    money decimal(10, 2)
) WITH (
    'connector.type' = 'jdbc',
    'connector.url' = 'jdbc:mysql://localhost:3306/test',
    'connector.table' = 'test2',
    'connector.username' = 'root',
    'connector.password' = 'root'
);


flink查询结果，streaming模式：
sql：select * from test2;


debug信息：










--

Best，
wldd

回复