Flink SQL如何将多个表的查询结果(列不同)聚合成一张表
select a.table_tmp1.r1 / a.table_tmp2.r2 这个是对同一行的数据进行操作，所以你需要先对table_tmp1和table_tmp2做一个join，将两个表的数据根据条件合并成一张表。 zilong xiao 于2020年7月8日周三 下午8:55写道： >...
Flink sql查询NULL值错误
Select id, name, if(type=1,2,null) From user ; 当我执行上面的sql的时候提示我 [ERROR] Could not execute SQL statement. Reason: org.apache.calcite.sql.validate.SqlVa...
flink sql-client下建的表无法查询怎么办？（sql-client与hive都不能查）
我现在用flink1.10.1版本在研究那个sql-client共hive集成，目前遇到这样一个问题想请教一下： standalone部署，3台机器，ｈｉｖｅ用的是ｃｄｈ５版本 hive1.1.0 按官方文档，进行了集成，ｈｉｖｅ建的表在flink sql-client下能查询，但反过来，flink...
flink 1.11 executeSql查询kafka表print没有输出
本人当前使用flink版本1.11.0，但是在执行executeSql后，print时没有在console打印出结果（查看kafka是一直有数据产生的）, sql如下: StreamExecutionEnvironment env = StreamExecutionEnvironment.getEx...
flink cdc 查询mysql binlog时，在 streaming模式下无反应
最近在使用flink cdc的时候，遇到需要用streaming mode来对收取的binlog日志进行后续相对复杂处理的需求。因为生产环境不允许mysql的RELOAD权限，之前在利用sql模式使用cdc的时候应用了 debezium.snap.shot.locking.mode = none的参...
用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确
我用相同的一个表自己 inner join 自己，取不同时间点，得到相同值 sql是这样，p5m 和 p0m 都是 snmpprobe.p_snmp_ifxtable 表，时间不同 select p0m.coltime, p0m.ifhcinoctets a, p0m.ifhcoutoctets c...
flink sql 使用自定义函数 返回嵌套行，查询报错 scala.MatchError，为什么？
目前无法通过t.* 将嵌套的字段查询出来。 val schema = tEnv.executeSql( """ | SELECT t.* FROM ( | SELECT EvtParser(request) as t FROM parsed_nginx_log | ) |""".stripMargi...
多查询允许用户在一个 Flink 作业中执行多个 SQL 查询有什么优势？
多查询允许用户在一个 Flink 作业中执行多个 SQL 查询有什么优势？
实时计算 Flink 版 + Hologres 交互式查询方案的优势？
实时计算 Flink 版 + Hologres 交互式查询方案的优势？
腾讯看点基于 Flink 构建万亿数据量下的实时数仓及实时查询系统
本文由社区志愿者路培杰整理，腾讯看点数据团队高级工程师王展雄在 Flink Forward Asia 2020 分享的议题《腾讯看点基于 Flink 构建万亿数据量下的实时数仓及实时查询系统》。内容包括：背景介绍架构设计实时数仓实时数据查询系统实时系统应用成果总结GitHub 地址 https://...
更新时间 2023-09-28 18:44:34
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
产品推荐
社区圈子
最佳实践
