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

flink 1.12.0版本的interval join 实现应该看哪个地方的源码?

是看flink-streaming-java模块的org.apache.flink.streaming.api.operators.co.IntervalJoinOperator? 还是看flink-table-planner模块的org.apache.flink.table.runtime.join.TimeBoundedStreamJoin? 或者是看Blink里面是怎么实现的?我用的p...

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

Flink sql join hive 维表

我在尝试使用 kafka 数据流 join hive 维表时,代码启动之初,Flink 会加载一次 hive 中的维表,但是后续插入到 hive 表中的数据不能被 join 到。 查看官网和中文社区的资料,提示设置 lookup.join.cache.ttl 配置参数,我将这个参数尝试设置在 TableEnv.conf 中,和 Table hits 设置在表名后,都没有起作用。 请问有大佬实...

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

有人知道flink sql里面大表join小表怎么去优化吗,比如sparksql的呢种,#Flink

有人知道flink sql里面大表join小表怎么去优化吗,比如sparksql的呢种,broadcast,将小表缓存进去,大表只需要读一次就可以了,不用shuffle的 #Flink

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

flink 1.9Temporal Table join时,日志报proctime字段不存在。

flink 1.9 创建Temporal Table,sql语法和创建普通表是同样的吗? 根据文档里的Temporal Table join时,代码报proctime字段不存在,这个proctime字段是系统自带的吧,不需要建表时再指定吧。

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

公司产品底层用的是flink 1.9, sql这块,1.9版本不支持join操作吗? #Flink

公司产品底层用的是flink 1.9, sql这块,1.9版本不支持join操作吗? #Flink

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

为啥flink sql 双流join 会报这个错啊。怎么调啊? #Flink

为啥flink sql 双流join 会报这个错啊。怎么调啊? #Flink

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

两个流join 除了sql写法 没有代码写法吗?#Flink

两个流join 除了sql写法 没有代码写法吗?#Flink

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

双流join很耗内存,哪位老哥处理过这种场景,一般需要做哪方面的优化呢? #Flink

双流join很耗内存,哪位老哥处理过这种场景,一般需要做哪方面的优化呢? #Flink

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

blink sql 实时计算,来源表5张,是否可以同时流join 2张以上的表

blink sql 实时计算,来源数据涉及5张表,每个表之间都互相都有关联,有些表是多条记录,有写表是一条数据,流的形式,是否可以同时join 5张表,如果之间有数据没有关联上,数据将会等到关联数据来时,在进行计算,是这样吗?

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

blink sql 实时计算,来源表5张,是否可以同时流join 2张以上的表

blink sql 实时计算,来源数据涉及5张表,每个表之间都互相都有关联,是否可以同时join 5张表,如果之间有数据没有关联上,数据将会等到关联数据来时,在进行计算,是这样吗?

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

产品推荐

阿里云实时计算Flink

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

+关注