问答 2024-03-05 来自:开发者社区

Flink CDC有没有遇到将pg number 类型解析出来是这个值的?

Flink CDC有没有遇到将pg number 类型解析出来是这个值的?

问答 2024-02-28 来自:开发者社区

Flink CDC Oracle存在字段CLOB类型,如何处理错误”ORA-01461"

做Flink CDC同步数据过程中,目标是Oracle数据库,其中某个字段较大被设置为CLOB类型,其中会遇到异常,”ORA-01461: 仅能绑定要插入LONG的LONG值“,请教各位专家问题如何解决?

问答 2024-02-14 来自:开发者社区

Flink CDC里Oracle表中主键是guid这个要配置啥类型呀?

Flink CDC里Oracle表中主键是guid这个要配置啥类型呀?

问答 2024-02-06 来自:开发者社区

Flink CDC里我mysql 数据库有个表它的字段定义为date类型,数值变化什么原因?

Flink CDC里我mysql 数据库有个表它的字段定义为date类型,比如在数据库中存储的值为2024-02-01,用flink cdc读取binlog这个字段的值变成了数字19754,是什么原因,该怎么解决?

问答 2024-02-01 来自:开发者社区

Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 怎么转换?

Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 转换成 cdc 类型为 decimal , 然后写到 starrocks 对应的类型为 decimal128 , StarRocks 不支持 decimal 作为主键的类型, 我也尝试过改 cdc 源码将 bigint unsigned 转换为 bigint , 但在存入 starrocks 时候,主键在 m....

问答 2024-01-24 来自:开发者社区

Flink CDC里flink-sql 中json_array 类型 怎么转成 array类型?

Flink CDC里flink-sql 中 json_array 类型 怎么转成 array 类型?

问答 2024-01-24 来自:开发者社区

Flink CDC里oracle里面date类型,这个情况怎么解决 ?

Flink CDC里oracle里面date类型,flink cdc2.4采集后变成1705674023000时间戳,而且还会自动加上8小时,怎么解决的啊?

问答 2024-01-24 来自:开发者社区

Flink CDC是在doris中自动建表 我可以到doris中重新更改表的类型是吧?

在Flink CDC中,如何通过yaml配置将两张MySQL表(jh_orders_0和jh_orders_1)中的数据合并到Doris的jh_orders表中,并且在两张源表的ID列存在相同值时实现合理的合并?

问答 2024-01-18 来自:开发者社区

Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真为啥?

Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真是怎么个情况?

文章 2024-01-08 来自:开发者社区

Flink CDC HBase字段类型与Flink SQL类型之间的转换

Flink CDC HBase字段类型与Flink SQL类型之间的转换可以通过以下Java代码实现: import org.apache.flink.table.types.DataType; import org.apache.flink.table.types.logical.LogicalType; import org.apache.flink.table.types.l...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注