阿里云文档 2025-06-06

如何使用双流JOIN语句,有哪些语法和示例

Flink SQL支持对动态表进行复杂而灵活的连接操作,本文为您介绍如何使用双流JOIN语句。

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

我有一个问题,当我使用两个Flink CDC 的表进行join并进行聚合,flink 会维护所有两?

我有一个问题,当我使用两个Flink CDC 的表进行join并进行聚合,flink 会维护所有两张表的状态数据么?好的,谢谢。 但是我发现有一个 CDC 的实践(https://developer.aliyun.com/article/1167820)里使用到多张实时表进行Join,即使使用了压缩的 Kafka,那么对 ckp 的影响还是无法避免的。 请教一下你们在实践中会考虑什么样的方式来进....

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

一张Flink CDC表,一张维表,使用left join,有使用system_time关联,如果?

一张Flink CDC表,一张维表,使用left join,有使用system_time关联,如果cdc表之前某一天的数据变更了,并且维表的数据也变更了,会导致,那天的数据并没有重新计算,而只是把那天的数据变更成变化的那条数据,如果这样,那天的数据就错了,这个怎么办?

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

Flink CDC中interval join 有什么办法可以把超过watermark又没匹配上的?

Flink CDC中interval join 有什么办法可以把超过watermark又没匹配上的数据收集到吗??找了半天没找到可以设置sideOutputLateData的地方?

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

Flink CDC中mysql cdc2.3 维表join丢数据,大家有遇到过吗?也没错误日志,这种

Flink CDC中mysql cdc2.3 维表join丢数据,大家有遇到过吗?也没错误日志,这种情况怎么排查?偶尔丢一条,过几天又丢一条

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

flink sql interval left outer join左边数据来了右边数据没来情况下?

flink sql interval left outer join左边数据来了右边数据没来情况下会直接输出(left, null),不会等待interval window结束仍没等到右边数据才输出吗?

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

大佬们现在咋处理flink cdc interval join场景的,现在测试下来一直报?

大佬们现在咋处理flink cdc interval join场景的,现在测试下来一直报【StreamPhysicalIntervalJoin doesn't support consuming update and delete changes which is produced by node TableSourceScan】这种错

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

flink sql维表join必须等值连接吗

select create_time ....... from log vdl left join dim_ip_local_range FOR SYSTEM_TIME AS OF vdl.create_time as dilr on int_ip >= dilr.start_num and int_ip 我想通过这种范围连接,批处理模式是可以的,...

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

Flink CDC中实时聚合是指什么 join?

Flink CDC中实时聚合是指什么 join?

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

表格存储Flink join ots维表的时候,出现了ots维表数据丢失的情况,这边看ots监控也有

表格存储Flink join ots维表的时候,出现了ots维表数据丢失的情况,这边看ots监控也有一些请求异常,麻烦帮忙看一下问题

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

产品推荐

阿里云实时计算Flink

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

+关注