你好,可以把ID和PRICE的类型改为NUMBER试一下,我这边flink-sql试过number类型对应到iceberg的decimal数据是正常的
| |
博星
|
|
15868861...@163.com
|
回复的原邮件
| 发件人 | Yanquan Lv |
| 发送日期 | 2024年06月26日 14:46 |
| 收件人 | |
| 主题 | Re: 回复:cdc读取oracle数据如何解析 |
你好,你的 ID 和 PRINCE 字段类型是 decimal 吗,decimal 默认的展示方式是使用 BASE64 处理
可以通过添加下面代
ializationSchema(includeSchema,
customConverterConfigs);
ha.fen...@aisino.com 于2024年6月25日周二 17:26写道:
> 数据没问题
> "ID" "NAME" "ADDTIME""PRICE"
> 1 "aa" 2024-6-25 14:21:33 12.22
>
> 发件人: 15868861416
> 发送时间: 2024
退订真的很麻烦,,,退订了好几次没搞懂
回复的原邮件
| 发件人 | ha.fen...@aisino.com |
| 日期 | 2024年06月25日 17:25 |
| 收件人 | user-zh |
| 抄送至 | |
| 主题 | Re: 回复:cdc读取oracle数据如何解析 |
数据没问题
"ID" "NAME" "ADDTIME""PRICE"
1 "aa" 2024-6-25 14:21:33
检查一下oracle中的DEBEZIUM.PRODUCTS这个表的数据,看你解析中有字符串
| |
博星
|
|
15868861...@163.com
|
回复的原邮件
| 发件人 | ha.fen...@aisino.com |
| 发送日期 | 2024年06月25日 15:54 |
| 收件人 | user-zh |
| 主题 | cdc读取oracle数据如何解析 |
根据文档的代码
JdbcIncrementalSource oracleChangeEventSource =
new OracleSourceBuilder()
.hostname(