问答 2022-06-22 来自:开发者社区

请问,flink sql 批任务,两表或多表join(inner join 或 outer join

请问,flink sql 批任务,两表或多表join(inner join 或 outer join),可不可以手动指定表,在流程图里传输到下游的传输方式为broadcast而不是根据关联条件中的字段hash的方式。

问答 2022-06-10 来自:开发者社区

关于flink sql join,有时候数据会漏,这个有啥解决方案?

关于flink sql join,有时候数据会漏,这个有啥解决方案?

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

flink sql regular join 是不是把两个流的数据都保存起来

Meta Source:【①群】Apache Flink China社区 Time:2021/11/10 17:13 Proposer:郑淑彬 Status:Resovled Content 郑淑彬 Q: flink sql regular join 是不是把两个流的数据都保存起来Jeff Zhang 简锋 看官方文档

问答 2021-12-08 来自:开发者社区

Flink SQL中的维表 JOIN是什么?

Flink SQL中的维表 JOIN是什么?

问答 2021-12-08 来自:开发者社区

Flink SQL中的双流 JOIN功能是什么?

Flink SQL中的双流 JOIN功能是什么?

问答 2021-12-08 来自:开发者社区

Flink SQL中LEFT JOIN 与 JOIN 的区别是什么?

Flink SQL中LEFT JOIN 与 JOIN 的区别是什么?

问答 2021-12-08 来自:开发者社区

flink sql lookup join中维表不可以是视图吗?

lookup join用的维表需要从两张mysql表做关联后得到,因此创建了一个视图。但发现flink sql不支持lookup join关联视图,会抛 Temporal Table Join requires primary key in versioned table, but no primary key can be found. 请问这种情况要怎么解决? CREATE VIEW q...

问答 2021-12-08 来自:开发者社区

想问一下Flink SQL 1.9版本支持维表join吗

想问一下,目前flink sql 1.9 可以通过sql的方式 join 关联外部数据源吗? 比如说通过sql DDL 定义一个Hbase的维表数据源,然后用sql join关联上。 CREATETABLEMyUserTable( hbase_rowkey_namerowkey_type, hbase_column_family_name1ROW, hbase_column_famil...

问答 2021-12-07 来自:开发者社区

Flink sql join问题

Hi all, 请问用Flink sql做双流join。如果希望两个流都只保存每个key的最新的数据,这样相当于每次join都只输出最新的一条记录。请问这种场景sql支持吗*来自志愿者整理的flink邮件归档

问答 2021-12-06 来自:开发者社区

flink sql消费kafka join普通表为何会性能爬坡?

大家好, flink sql消费kafka join普通表是会性能爬坡吗? 背景是flink 1.12.0 使用flink sql在yarn per-job发布,消费kafka topic=trades,然后join 数据库里的维表 shop_meta 现在发现每次重启flink sql job,或上游突然增加大量写入时,flink sql的消费速度总是慢慢增加上来,这样就会造成上游积压,等...

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

产品推荐

阿里云实时计算Flink

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

+关注