各位,我想知道,既然数据全部读取过来存放内存,我flink sql窗口关闭之后再次查询这个cdc映射

各位,我想知道,既然数据全部读取过来存放内存,我flink sql窗口关闭之后再次查询这个cdc映射的表,那又得同步一次全量数据吗?

flink sql创建表成功,查询却报错block data,大家有没有碰到这现象

flink sql创建表成功,查询却报错block data,大家有没有碰到这现象

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

使用flink SQL 创建映射后,查询报了一个这个错误,有高人知道是什么原因吗?

使用flink SQL 创建映射后,查询报了一个这个错误,有高人知道是什么原因吗?

flink sql 可以查询 clickhouse 吗

flink sql 可以查询 clickhouse 吗

如何用flink sql持续查询过去30分钟登录网站的人数?

例如,用户在以下时间点登录:无, 12:02, 12:13, 12:15, 12:31, 12:40, 12:45, 无 那么我期望在以下时间点(实际查询可能在任意时间点)获取到的结果数为 12:01 (0), 12:03:(1), 12:14 (2), 12:16(3), 12:30 (4), 1...

Flink SQL>查询的hive表数据全L部为NUL

Flink SQL>select * from table1; 在Flink客户端查询hive数据,结果每个字段全为NULL,但数据条数是对的,select count是正确的,查具体数据就是NULL,不知何故?同样的查询在hive客户端是可以查到数据的 hive表时orc文件load的数据。...

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-client下建的表无法查询怎么办?(sql-client与hive都不能查)

我现在用flink1.10.1版本在研究那个sql-client共hive集成,目前遇到这样一个问题想请教一下: standalone部署,3台机器,hive用的是cdh5版本 hive1.1.0 按官方文档,进行了集成,hive建的表在flink sql-client下能查询,但反过来,flink...

flink sql 使用自定义函数 返回嵌套行,查询报错 scala.MatchError,为什么?

目前无法通过t.* 将嵌套的字段查询出来。 val schema = tEnv.executeSql( """ | SELECT t.* FROM ( | SELECT EvtParser(request) as t FROM parsed_nginx_log | ) |""".stripMargi...

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
阿里云流计算 Flink SQL 核心功能解密
Flink Streaming SQL 2018
立即下载 立即下载 立即下载

实时计算 Flink版sql相关内容