[
https://issues.apache.org/jira/browse/FLINK-15313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15313:
-----------------------------------
Labels: pull-request-available (was: )
> Can not insert decimal with precision into sink using TypeInformation
> ---------------------------------------------------------------------
>
> Key: FLINK-15313
> URL: https://issues.apache.org/jira/browse/FLINK-15313
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: Jingsong Lee
> Assignee: Jark Wu
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.10.0
>
>
> Sink DDL:
>
> {code:java}
> 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
> {code}
> 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)
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
