flink SQL 的相关内容

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

flink sql太多insert into语句问题我们有一个场景需要从一张kafka源表写很多不同告警规则到同一张告警目标表。规则数量大概有300多个，采用纯flink sql实现。方案一是采用创建视图，将不同规则union all起来，再将视图插入目标表，发现算子都chain成了一个，因为flink sql算子的名称是flink sql内容，所以算子名称长度超过限制而失败。因而转向方案.....

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

Flink sql jdbc Partitioned Scan timestamp不生效

Hi：我在使用flink sql jdbc connector测试partitioned scan功能，发现指定 scan.partition.column 为timestamp类型时，scan.partition.lower-bound 和scan.partition.upper-bound指定具体的值后，没有读取到相关数据，哪位大佬帮忙解答下谢谢*来自志愿者整理的flink

问答 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 collect函数使用问题

使用场景如下，将kafka源表通过flink sql处理成mongodb汇表存入。按照班级进行group by，输出对应班级所有的学生数据集合。请问用flink sql自带的collect函数能实现吗？如果能的话要怎么写sql? 如果不能的话要怎么写UDAF，有例子参考吗？谢谢！ kafka源表：班级学号姓名年龄 1 20001 张三 15 2 20011 李四 16 1 20002 .....

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