问答 2024-05-07 来自:开发者社区

flink sql 中的lookup join不支持MiniBatch模式吗?

flink版本1.15 请问flink sql 中的lookup join不支持MiniBatch模式吗? 我在代码中设了下面3个参数来开启微批处理:tableEnv.getConfig().set("table.exec.mini-batch.enabled", "true");tableEnv.getConfig().set("table.exec.mini-batch.allow-late....

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

在Flink 多表 join 写入 es ,有什么其他方案嘛?

在Flink 多表 join 写入 es ,有什么其他方案嘛?

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

有人用过FLINK SQL的事件时间 Temporal Join吗?

有人用过FLINK SQL的事件时间 Temporal Join吗,我这边left表来源于kafka,right表也来源于kafka,left表定义了水位线,right表定义了水位线和主键,2个表关联的时候,随便怎么弄都不触发执行,请问谁能帮忙看下吗?

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

Flink的LOOKUP JOIN 支持子查询吗?

Flink的LOOKUP JOIN 支持子查询吗?

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

请问flink sql 事件时间 Temporal Join 设计多个并行度不触发计算

环境说明:flink 1.15 场景描述:left 表是一个来源于kafka的表且定义了水位线,right表是来自于mysql cdc的表,right表定义了主键和水位线,按flink官方说法right表就是一个版本表了。2个表按FOR SYSTEM_TIME AS OF事件时间的方式关联。且关联字段都是主键。在执行环境中设置了程序的并行度为3。 问题描述:right表本身有不少数据了,当lef....

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

flink中lookup Join hologres的维表,可以指定查bitmap吗?

flink中lookup Join hologres的维表,可以指定查bitmap吗?如果查询条件同时走clustering key和bitmap时,发现bitmap的速度更快

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

flink中,join如果不指定窗口,会把join结果一直存储下来吗?

flink中,join如果不指定窗口,会把join结果一直存储下来吗?

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

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

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

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

在Flink中,你可以通过以下方法为join操作设置并行度

在Flink中,你可以通过以下方法为join操作设置并行度: 使用ExecutionEnvironment的setParallelism方法。首先,你需要创建一个ExecutionEnvironment实例,然后调用setParallelism方法来设置并行度。例如: ExecutionEnvironment env =...

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

产品推荐

阿里云实时计算Flink

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

+关注