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

请问flink sql 事件时间 Temporal Join 不触发计算

环境说明:flink 1.15 场景描述:left 表是一个来源于kafka的表且定义了水位线,right表是来自于mysql cdc的表,right表定义了主键和水位线,按flink官方说法right表就是一个版本表了。2个表按FOR SYSTEM_TIME AS OF事件时间的方式关联。且关联字段都是主键。 问题描述:right表本身有不少数据了,当left来一条数据的时候结果没有触发计算。....

问答 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-01-31 来自:开发者社区

请教个问题,flink sql 维表 jdbc lookup join,如何更新结果数据呢?

请教个问题,flink sql 维表 jdbc lookup join,当左表数据不更新时,维表变动,如何更新结果数据呢?

文章 2024-01-21 来自:开发者社区

这个问题是由于Flink在执行SQL语句时,无法找到合适的表工厂来处理JOIN操作。

Flink中这个是啥情况,jar包都放到lib下面,还是出这个问题?Flink SOL> INSERT INTO tenant_userSELECT t.agent_id, 这个问题是由于Flink在执行SQL语句时,无法找到合适的表工厂来处理JOIN操作。你可以尝试以下方法解决这个问题: 确保你的Flink版本支持JO...

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

如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好?

请问下,如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好一点哈?

问答 2023-11-30 来自:开发者社区

flink sql 多个left join,开启mini batch后乱序,大家有什么解决方案么?

flink sql 多个left join,每个join都是不同的字段。开启mini batch后乱序,大家有什么解决方案么?

问答 2023-11-30 来自:开发者社区

Flink CDC有时间帮忙看一下flink sql 多表left join 写入失败的问题嘛?

Flink CDC有时间帮忙看一下flink sql 多表left join 写入失败的问题嘛,总是报检查点写入失败?

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

Flink CDC2.4.1 flink1.14.6,sql left join一些表,这个咋解决?

Flink CDC2.4.1 flink1.14.6,sql left join一些表,非主键关键,会丢失delete同步,这个咋解决?

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

产品推荐

阿里云实时计算Flink

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

+关注