[jira] [Commented] (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:comment-tabpanel=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)
[jira] [Commented] (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:comment-tabpanel=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)
