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

Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗?

Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗?configuration.set(ExecutionConfigOptions.TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER, ExecutionConfigOptions.TypeLengthEnforcer.IGNORE);这个好像没有啥用啊,有大佬知道这个怎么解决吗?

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

Flink CDC里设置这个参数,没有捕获到新增字段的数据,其他数据也异常怎么回事?

Flink CDC里sqlserver-cdc设置这个参数,没有捕获到新增字段的数据,其他数据也异常是怎么回事?

问答 2023-12-10 来自:开发者社区

Flink CDC只监听一个字段 其他字段数据可以拿到吗?

Flink CDC只监听一个字段 其他字段数据可以拿到吗?

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

Flink CDC读取源表中的时间戳字段获取不到字段的数据啊 ?

Flink CDC读取源表中的时间戳字段获取不到字段的数据啊 都是空 源表时间戳字段设置的timestamp类型,cdc里读取的时候timestamp、bigint、string都获取不到数据(null)?

文章 2023-11-16 来自:开发者社区

Flink CDC中mysql 字段设置了默认值 ,然后插入数据时 指定该字段为null 会返回字段默认值 而不是null?

是的,如果在MySQL中为某个字段设置了默认值,并且在插入数据时没有指定该字段的值,则会使用默认值作为该字段的值。即使在插入数据时指定了该字段的值为null,也会被忽略并使用默认值。这是因为MySQL中的默认值是在插入数据时自动应用的,而不是在查询数据时。因此,无论插入数据时是否指定了该字段的值,都...

问答 2023-09-20 来自:开发者社区

Flink CDC已经上线的任务,后续进行表结构变更新增字段,这种对数据没啥影响吧?

Flink CDC已经上线的任务,后续进行表结构变更新增字段,无状态启动从指定时间,这种对数据没啥影响吧?

问答 2023-07-19 来自:开发者社区

请问如果表字段中有flink的关键字段, 但是业务数据需要同步这个字段数据, 这种情况有什么方式?

请问如果表字段中有flink的关键字段, 但是业务数据需要同步这个字段数据, 这种情况有什么方式处理吗, 比如说 floor。

问答 2023-07-13 来自:开发者社区

Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?

问题1:Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?问题2:不能用debezium-json格式拿op字段数据吗

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

我用Flink CDC 去监控mysql 有三个字段是日期类型的 但是cdc读出来为什么是数据啊?

我用Flink CDC 去监控mysql 有三个字段是日期类型的 但是cdc读出来为什么是数据啊! 这是什么鬼

问答 2022-12-20 来自:开发者社区

发现flink cdc postgres部分字段没有按照字段名去生成insert into,而是数据

发现flink cdc postgres部分字段没有按照字段名去生成insert into,而是用数据的index去匹配的。这个大家有碰到过吗? 类似于insert into xxx(code,en_name, cn_name) values (...); 如果写成 select($("code"), ${"cn_name"}, $("en_name")) 插入的数据就会反了。 如果按照相应的顺....

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问