文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决

问题一:Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后有点数据开始从0聚合? Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后,有点数据开始从0开始聚合了啊?有的数据是正常的,有的数据的清0了,我这边没有设置TTL,状态也会过期吗? 参考回答: 在Flink CDC中进行Lookup Joi...

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决
问答 2024-03-06 来自:开发者社区

Flink双流JO IN 的TTL 怎么更改?具体怎么使用?

Flink双流JO IN 的TTL 怎么更改?具体怎么使用?

文章 2024-02-26 来自:开发者社区

Flink报错问题之flink双流join报错如何解决

问题一:滑动窗口数据存储多份问题 由于第一次咨询,我不确定上一份邮件大家是否收到。 想咨询下大家,为什么使用 datastream api 的话,滑动窗口对于每条数据都会在 state 中存 size / slide 份? *来自志愿者整理的flink邮件归档 参考答案: ...

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

Flink CDC里之前用mysql数据库join比较慢,这种join性能会比较好吗?

Flink CDC里之前用mysql数据库join比较慢,所以才改成同步宽表到es,不知道doris,starorcks 这种join性能会比较好吗?

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

Flink cdc3.0 支持变化的表和多张维表 join 了吗?

有4张表left join成一张表,每张表变化都要查其他几张表的历史数据,这种情况 flink cdc3.0支持吗?之前的2.x版本问过好像不支持。有关联的字段,但是主键不相同怎么做啊?另外字段不同的多张表合并成一张大宽表,如果相同的主键怎么做?

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

Flink多流join能控制优先级吗?

Flink多流join能控制优先级吗?我有一个数据流connect广播流 广播流优先级好像很低 每次都得等数据流积压消完 才开始消费

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

有没有flink sql 输出的时候这个join的数据膨胀扛不住啊?

有没有flink sql 一行转多列时跳过lateral join的方法啊。输出的时候这个join的数据膨胀扛不住啊?我在udtf里面的输出已经完全可以用了,可是flink sql不允许直接查询引用这个表

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

flink sql cdc现在支持interval join嘛?

flink sql cdc现在支持interval join嘛?

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

Flink CDC里flink sql 维表 jdbc lookup join,如何更新结果数据呢?

Flink CDC里flink sql 维表 jdbc lookup join,当左表数据不更新时,维表变动,如何更新结果数据呢?

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

Flink实时数据的时态表join 我这里为啥一直没有输出为什么?

Flink实时数据的时态表join 我这里为啥一直没有输出为什么? String sql = "select o.,r.rate from alan_orderTable as o,Lateral table (alan_rateDim(o.order_time)) r where r.currency = o.currency ";// String sql = "select...

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

产品推荐

阿里云实时计算Flink

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

+关注