[FLINK-17948] Use new type system for SQL Client collect sink

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.13.0
• Component/s: Table SQL / Client

Environment

mysql:
image: mysql:8.0
volumes:

• ./mysql/mktable.sql:/docker-entrypoint-initdb.d/mktable.sql
  environment:
  MYSQL_ROOT_PASSWORD: 123456
  ports:
• "3306:3306"

• Assignee: Shengkai Fang
• Reporter: Shengkai Fang
• Created: 26/May/20 14:55
• Updated: 13/Apr/21 02:27
• Resolved: 13/Apr/21 02:27

Description

My job is following:

 

CREATE TABLE currency (
  currency_id BIGINT,
  currency_name STRING,
  rate DOUBLE,
  currency_timestamp  TIMESTAMP,
  country STRING,
  precise_timestamp TIMESTAMP(6),
  precise_time TIME(6),
  gdp DECIMAL(10, 6)
) WITH (
   'connector' = 'jdbc',
   'url' = 'jdbc:mysql://localhost:3306/flink',
   'username' = 'root',
   'password' = '123456',
   'table-name' = 'currency',
   'driver' = 'com.mysql.jdbc.Driver',
   'lookup.cache.max-rows' = '500',
   'lookup.cache.ttl' = '10s',
   'lookup.max-retries' = '3')

When select * from currency, the precision of results are not as same as expected.  The precision of field precise_timestamp is 3 not 6, and the field gdp has more digit as expected. 

 

The data in mysql is following:

Issue Links

• links to: TIMESTAMP WITH LOCAL TIME ZONE can't be used in SQL Client query