You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/04/11 02:59:00 UTC

[jira] [Resolved] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support.

     [ https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Qingsheng Ren resolved FLINK-34690.
-----------------------------------
      Assignee: Hongshun Wang
    Resolution: Fixed

> If data from upstream is decimal and primary key , starrocks sink will not support.
> -----------------------------------------------------------------------------------
>
>                 Key: FLINK-34690
>                 URL: https://issues.apache.org/jira/browse/FLINK-34690
>             Project: Flink
>          Issue Type: Bug
>          Components: Flink CDC
>            Reporter: Hongshun Wang
>            Assignee: Hongshun Wang
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: cdc-3.1.0
>
>
> h3. What's the problem
> Flink only have bigint type, if mysql data is unsigned bigint , maybe out of range, so cast to DECIMAL(20, 0).
> If starrocks supports unsigned bigint, maybe can transform DECIMAL(20, 0) to unsigned bigint in sink. To be honest, unsigned bigint is not in SQL standard, thus many databases maybe not support it. [https://docs.starrocks.io/zh/docs/sql-reference/sql-statements/data-types/data-type-list/]
> And starrock not support DECIMAL as primary key, thus should be transformed to String. I think we can fix it.
>  
> h3. How to solve
> StarRocks is not support Decimal as primary key, so decimal should be cast to VARHCAR.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)