最近遇到一个问题,flink cdc通过sql的方式连接上百张oracle表导致oracel服务器的

最近遇到一个问题,flink cdc通过sql的方式连接上百张oracle表导致oracel服务器的cpu占比过高,可以通过什么参数调节吗?

flink cdc的sql实现方式能单独设定算子的并行么?现在flink sql 有几个算子背压很高

flink cdc的sql实现方式能单独设定算子的并行么?现在flink sql 有几个算子背压很高,没办法解决

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

14 课时 |
4329 人已学 |
免费
开发者课程背景图

有一个问题 flink cdc 使用sql 进行group by 录入的时候,长时间会造成内存溢出吗

有一个问题 flink cdc 使用sql 进行group by 录入的时候,长时间会造成内存溢出吗

各位大佬,请教一下,如果在flink cdc sql客户端 使用SQL查询表,怎么能记录原系统的数据

各位大佬,请教一下,如果在flink cdc sql客户端 使用SQL查询表,怎么能记录原系统的数据是变更还是删除操作状态及时间呢?

各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以

各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以指定输出 schema 信息嘛? 看到好像只有 api 中可以指定 .deserializer(new JsonDebeziumDeserializationSchema(true)). flink ...

当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql jo

当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql job报以下错误提示Equality field columns shouldn't be empty 已经设置了主键,使用了iceberg 的v2,请问是要在哪里设置一下吗

大家 flink cdc 用的 是不是都是 datastream 方式? 如果sql 作业 貌似

大家 flink cdc 用的 是不是都是 datastream 方式? 如果sql 作业 貌似 连接数比较多

flink cdc sql的 ARRAY<ROW<>> 类型可以循环入库吗?

因为要把ARRAY 按 ROW 拆成多行入库。但对Kafka来说是一条JSON消息 ,只是某个Json属性映射成了ARRAY> 类型。 类似于这种格式:

flink cdc sql 可以只同步全量batch跑吗?

flink cdc sql 可以只同步全量batch跑吗?

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

产品推荐

社区圈子

数据库
数据库
分享数据库前沿,解构实战干货,推动数据库技术变革
253177+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
阿里云流计算 Flink SQL 核心功能解密
Flink Streaming SQL 2018
立即下载 立即下载 立即下载