[FLINK-15313] Can not insert decimal with precision into sink using TypeInformation

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jingsong Lee
• Created: 18/Dec/19 09:43
• Updated: 26/Dec/19 04:33
• Resolved: 26/Dec/19 04:32

Description

Sink DDL:

 

val sinkDDL =
  s"""
    |CREATE TABLE T2 (
    |  d DECIMAL(10, 2),
    |  cnt INT
    |) with (
    |  'connector.type' = 'filesystem',
    |  'connector.path' = '$sinkFilePath',
    |  'format.type' = 'csv',
    |  'format.field-delimiter' = ','
    |)
  """.stripMargin

Using blink with batch mode. (ensure insert BinaryRow into sink table)

 

In FLINK-15124 , but we still use wrong precision to construct DataFormatConverter. This will lead to exception when inserting BinaryRow. (BinaryRow need correct precision to get)

 

Issue Links

• duplicates: FLINK-15309 Execute sql appear "NumberFormatException: Zero length BigInteger"
• duplicates: FLINK-15310 A timestamp result get by a select sql and a csvsink sql is different
• duplicates: FLINK-15326 Add document description for DECIMAL(38, 18) when the sink table uses json schema
• is related to: FLINK-15309 Execute sql appear "NumberFormatException: Zero length BigInteger"
• is related to: FLINK-15310 A timestamp result get by a select sql and a csvsink sql is different
• is related to: FLINK-15326 Add document description for DECIMAL(38, 18) when the sink table uses json schema
• links to: GitHub Pull Request #10667