[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827404#comment-17827404
]
Hongshun Wang commented on FLINK-34690:
---------------------------------------
[~renqs] ,[~Leonard] , [~Lv Yanquan] , [~banmoy] , CC
> 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
>
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
