问答 2023-12-13 来自:开发者社区

Flink sql中是怎样处理这类数据的呢?

Flink sql中是怎样处理这类数据的呢?我看ctas作业好像可以过滤

问答 2023-12-03 来自:开发者社区

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

问答 2023-12-03 来自:开发者社区

Flink sql通过jdbc connector写入mysql,怎么保证数据的一致性呢?

Flink sql通过jdbc connector写入mysql,怎么保证数据的一致性呢?jdbc connector有实现两阶段提交嘛?

问答 2023-11-16 来自:开发者社区

Flink CDC中sql-client针对kafka的protobuf格式数据建表,有人遇到过吗?

Flink CDC中sql-client 针对kafka的protobuf格式数据建表,老是找不到pb类名,报java.lang.ClassNotFoundException 有人遇到过吗?求给点思路,不知道如何解决了?

文章 2023-11-15 来自:开发者社区

Flink CDC中flink sql 如果缓存起来所有的数据,然后基于这个数据做查询?

在Flink SQL中,可以使用CREATE TEMPORARY SYSTEM VIEW语句来创建临时视图,以缓存数据。临时视图在会话级别上是可见的,可以在多个查询之间重用。以下是一个简单的例子,说明如何创建临时视图: CREATE TEMPORARY SYSTEM VIEW cached_data AS SELECT * F...

问答 2023-11-15 来自:开发者社区

Flink CDC中flink sql 如果缓存起来所有的数据,然后基于这个数据做查询?

Flink CDC中flink sql 如果缓存起来所有的数据,然后基于这个数据做查询?

问答 2023-11-12 来自:开发者社区

Flink sql-client 针对kafka的protobuf格式数据建表,有人遇到过吗?

Flink sql-client 针对kafka的protobuf格式数据建表,老是找不到pb类名,报java.lang.ClassNotFoundException 有人遇到过吗?求给点思路,不知道如何解决了?

问答 2023-11-07 来自:开发者社区

flink sql 按日期统计数据,日期变更,怎样撤回已经落库的数据?

flink sql 按日期统计数据,日期变更,怎样撤回已经落库的数据?多个大表join状态会很大,实时join的话,状态读写的效率是影响实时性的主要因素吧

问答 2023-11-01 来自:开发者社区

Flink CDC中flink sql 全量抽取数据的时候 不能走checkpoint嘛?

Flink CDC中flink sql 全量抽取数据的时候 不能走checkpoint嘛?

问答 2023-10-30 来自:开发者社区

flink sql 使用udtf ,有没有办法清理udtf内的过期数据?

flink sql 使用udtf ,有没有办法清理udtf内的过期数据

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

产品推荐

数据库

分享数据库前沿,解构实战干货,推动数据库技术变革

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问