Jingsong Lee created FLINK-15313:
------------------------------------
Summary: 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
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)
