[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835958#comment-17835958
]
Qingsheng Ren commented on FLINK-34690:
---------------------------------------
flink-cdc master: abb98ee257527079a013462de0893bb9e2276693
> 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
> 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)
