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 cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

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

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

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

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

Flink CDC里源mongo用mongo SQL CDC到mysql,这怎么回事?

Flink CDC里源mongo用mongo SQL CDC到mysql,slots配置 10-1000个都会耗尽,怎么回事?8C 32G机器,flink设置20G。

Flink CDC里 flink sql没有写这个参数,但是报错出现了这个怎么办?

postgre-cdc Doesn't support postgres type 'uint8' yetFlink CDC里 flink sql没有写这个参数,但是报错出现了这个怎么办?我在flink sql和数据库里没搜到对应的类型,主键是bigint类型。

Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,错误怎么办?

Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,就如下错误:Flink CDC,cdc2.4,flink1.17.2,mysql8;Flink SQL> select * from mysql_binlog;[ERROR] Could not execute ...

Flink CDC 里flink sql >= 这种底层不是filter算子么?

Flink CDC 里flink sql >= 这种底层不是filter算子么?

Flink CDC 里有没有人试过,这个配置的sql 是不是必须是要监控的表?

Flink CDC 里有没有人试过,这个配置的sql 是不是必须是要监控的表?

Flink CDC 里有没有方法只通过flink sql 获取到 row 的方式不?

Flink CDC 里有没有方法只通过flink sql 获取到 row 的changlog event type么?

Flink CDC 里SQL create table like语句,只修改with参数嘛?

Flink CDC 里flinkSQL create table like语句,可以实现不对字段做增删,只修改with参数嘛?比如说这样:可是如果我在source1表的基础上,任意加一个字段,都可以生成source2表,这叫不可以复用吗?官网上的案例是加了个watermark,没有操作字段我改db名...

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink CDC 打造 企业级实时数据集成方案
任庆盛|Flink CDC + Kafka 加速业务实时化
Flink CDC Meetup PPT - 龚中强
立即下载 立即下载 立即下载

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关