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

我是用flink sql做的join 拿到的数据,我想针对更新操作时比较具体哪个字段发生更新, 但是

我是用flink sql做的join 拿到的数据,我想针对更新操作时比较具体哪个字段发生更新, 但是flink sql拿到的row类型数据分为update_before和update_after,这是两条数据,我怎么能关联起来,判断具体发生变化的字段?

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

mysql cdc表做Flink sql join ,支持这个语法吗?

mysql cdc表做Flink sql join 的时候支持FOR SYSTEM_TIME AS OF 语法吗?

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

Flink CDC,data-stream 如何实现想 sql-join 一样的全量 join 呢?

sql join 可以全量, 但 data-stream 中必须配置 window, 那 data-stream 如何实现想 sql-join 一样的全量 join 呢?

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

各位大佬 有遇到过 flink sql cdc left join 少数据问题吗?

各位大佬 有遇到过 flink sql cdc left join 少数据问题吗?

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

使用flink sql CDC 多表Interval Join 的时候, 报错

使用flink sql CDC 多表Interval Join 的时候, 报错:StreamPhysicalIntervalJoin doesn't support consuming update and delete changes which is produced by node TableSourceScan, 有人知道怎么解决吗?

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

有遇到过 flink SQL join 聚合结果缺失的情况吗?

有遇到过 flink SQL join 聚合结果缺失的情况吗?

问答 2022-11-25 来自:开发者社区

flink1.13.6 版本 使用flink sql interval left join 不生效

在使用flink interval join 时 使用left join 关联两个表,并且输出到kafka中,发现 输出的是撤回流 ,左表并不存数据在state中,一直输出不关联右表的数据,是版本太低不支持interval left join 吗

问答 2022-09-28 来自:开发者社区

flink sql 批处理的时候,用left join 产生了数据倾斜,一般怎么处理啊?

flink sql 批处理的时候,用left join 产生了数据倾斜,一般怎么处理啊?

问答 2022-09-02 来自:开发者社区

flink sql,1.14以后怎么流join mysql呢 官网文档显示不支持join了?

flink sql,1.14以后怎么流join mysql呢 官网文档显示不支持join了?

问答 2022-07-29 来自:开发者社区

请问下通过flink sql读取hologres 的两张表的 binlog,然后如何进行join?

请问下通过flink sql读取hologres 的两张表的 binlog,然后如何进行join?

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

产品推荐

阿里云实时计算Flink

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

+关注