You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/26 04:33:00 UTC
[jira] [Resolved] (FLINK-15313) Can not insert decimal with
precision into sink using TypeInformation
[ https://issues.apache.org/jira/browse/FLINK-15313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu resolved FLINK-15313.
-----------------------------
Resolution: Fixed
[FLINK-15313][table-blink] Fix can't insert decimal data into sink using TypeInformation
- 1.11.0: fb0cd0ee3cc06de078b60bd56fb89d951877e67d
- 1.10.0: 7eb80ff3745aa9619af4835da24f4a7062b8e229
[hotfix][hive] Use TableUtils.collectToList(Table) to verify query result
- 1.11.0: 32ff63e7fe23e69d6a4421e51e4b6d00578dfcb1
- 1.10.0: 019a4e75fdd8aff9f038a1d8b80a4128e1de5950
[hotfix][table-api] Use new type system for CsvTableSink
- 1.11.0: f7ac7b9bc2a1fb90e6f06ca26d18b131e034a70d
- 1.10.0: 3817455eb79c14a1574c9a6da11b7363b2c7b805
[hotfix][table-common] Add toNullable() and legacyDecimalToDefaultDecimal() TypeTransformations
- 1.11.0: 18717431590f1f2768add8dbb3a876df70e6f7cd
- 1.10.0: 4deb170fca6f1c9caf59109582323ed7d8a7d854
> 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
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)