Flink CDC里在mysql库中新增一个mysql表之后,flink-sql就挂了是为啥?

Flink CDC里在mysql库中新增一个mysql表之后,flink-sql就挂了:2024-04-19 10:47:32,715 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: ods_xxx_c...

FLINK SQL 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

FLINK SQL 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

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

flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

FLINK SQL CDC 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

FLINK SQL CDC 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去? 这种怎么处理,让脚本运行下去啊?

在IDEA 2023 中执行flink sql报错,请问怎么配置内存?

在IDEA 2023 中执行flink sql报错,请问怎么配置内存?## java.io.IOException: Insufficient number of network buffers: required 2, but only 0 available. The total number ...

请教一个问题 flink sql ,Flink 1.19 开始了报错,如何解决?

请教一个问题 flink sql ?sql 中 left join 的很多次 ,Flink 1.19 开始了报错?

我在flink sql client 执行这个代码 同步只会执行一次 修改源表数据后 如何解决?

我在flink sql client 执行这个代码 同步只会执行一次 修改源表数据后 目标表没有发生变化?

flink sql数据写入kafka,会出现key为before、after及op,怎么把这些去掉?

flink sql数据写入kafka,会出现key为before、after及op,怎么把这几个去掉?我写入的数据直接是json格式

Flink sql修改ddl能通过savepoint重启吗?

Flink sql修改ddl能通过savepoint重启吗?

Flink CDC里有大哥有同步sql server的实践吗?

Flink CDC里有大哥有同步sql server的实践吗?我们有些采购的系统用的sql server需要采集他们的数据我发现我的check point好像没用,不生效。我用的这个connector。读checkpoint必须initial吗?sql server 开启cdc对于生产的负载大吗?需...

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

产品推荐

社区圈子

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