问答 2023-06-29 来自:开发者社区

Flink CDC 中mysql 的 time 对应 cdc 的 timestamp 类型吗?

Flink CDC 中mysql 的 time 对应 cdc 的 timestamp 类型吗?

问答 2023-06-29 来自:开发者社区

各位大佬,Flink CDC这个timestamp类型,怎么才能把T去掉,还是timestamp类?

各位大佬,Flink CDC这个timestamp类型,怎么才能把T去掉,还是timestamp类型呢? 试了好几种方法都不行

问答 2023-06-29 来自:开发者社区

Flink CDC中有没有遇到过上游timestamp类型数据为'但是这个时间戳值是非法的无法写入?

Flink CDC中有没有遇到过上游timestamp类型数据为'0000-00-00 00:00:00',通过mysql-cdc消费写入下游mysql中,会被转化为'1970-01-01 08:00:00',但是这个时间戳值是非法的无法写入下游的情况?The TIMESTAMP data type is used for values that contain both date and ti....

问答 2023-06-18 来自:开发者社区

Flink CDC中我没有用水位线,就是根据时间字段进行了分组。为啥还是会报这类型的错?

Flink CDC中我没有用水位线,就是根据时间字段进行了分组。为啥还是会报这类型的错?pyflink.util.exceptions.tableexception: org.apache.flink.table.api.TableException: StreamPhysicalOverAggregate doesn't support consuming update and delete ....

问答 2023-06-18 来自:开发者社区

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

问答 2023-06-04 来自:开发者社区

请教下,Flink CDC 中oracle同步到oracle,ROWID类型,对应flink什么类?

请教下,Flink CDC 中oracle同步到oracle,ROWID类型,对应flink什么类型呢?source用的oracle-cdc,sink用的jdbc。按照oracle-cdc的文档说明,flink里用BYTES类型,但是会报ORA-00932的错误?

问答 2023-05-23 来自:开发者社区

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我?

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我使用的是sql-client提交的sql,我在官方文档没找到怎么设置?

问答 2023-05-23 来自:开发者社区

Flink CDC中我们oracle里面有这个类型的,这个大家一般怎么解决的啊?

问题1:Flink CDC中我们oracle里面有这个类型的,这个大家一般怎么解决的啊? 问题2:是要转,但是全量没少8小时

问答 2023-05-14 来自:开发者社区

Flink ORACLE CDC不支持CLOB类型吗?

Flink ORACLE CDC不支持CLOB类型吗? 2023-05-12 08:42:22.744 ERROR [hange-event-source-coordinator] i.d.r.TableSchemaBuilder:(269) - Failed to properly convert data value for 'ORARACB.KQGLXT.WB6_META.META_CON....

问答 2023-05-01 来自:开发者社区

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,用mysql 客户端查询没有问题,但是用 cdc 导出来 就差8小时,怎么办?

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

产品推荐

阿里云实时计算Flink

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

+关注