Flink CDC里flinksql 怎么设置uid?

Flink CDC里flinksql 怎么设置uid?我需要读取flinksql的savepoint。状态现在单调递增,知道里面肯定有问题,但是sql逻辑太复杂了,不读取savepoint根本不知道里面存了啥。我的意思是我想要知道怎么设置flinksql算子级别的uid?不是要flink从某个sav...

Flink CDC里我代码里设置了 这个,拉取不到历史数据怎么办?

Flink CDC里我代码里设置了 StartupOptions.initial();拉取不到历史数据怎么回事呢?我自定义Debezium 只保留 insert 的binlog的。check poit 我设置本机地址,我每次调试代码都将checkpoit清除掉来验证是否从头读取。有read ,但是我...

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC里这个咋设置呢?

Flink CDC里这个咋设置呢?

Flink CDC里mysql-cdc连接报错,这个ip和端口都是通的,连接池设置的200怎么办?

Flink CDC里mysql-cdc连接报错,这个ip和端口都是通的,连接池设置的200,有遇到这样问题的么?

Flink CDC 里怎么设置idea打开一个新的github项目,自动索引文件吗?

Flink CDC 里怎么设置idea打开一个新的github项目,自动索引文件吗?每次打开打的项目,都特别的卡,然后索引30多分钟,能不能设置成 间隔性的,打开某个目录,再索引,实在是太卡了,电脑都要烧冒烟了。

Flink CDC 里我的任务又全局挂了 flink设置的5次重试怎么办?

Flink CDC 里我的任务又全局挂了 flink设置的5次重试 akka timeout设置的2min 数据是mysql到cdc再sink到kafka 。 这个异常还出现 是说明mysql到cdc之间通信异常么?还是cdc 到下游kafka之间的subtask没搞完?现在不知道根因是在哪里 ?或...

Flink CDC 里整库同步的时候要排除表需要怎么配置?我设置debezium属性没有效果怎么办?

Flink CDC 里整库同步的时候要排除表需要怎么配置?我设置debezium属性没有效果怎么办?

Flink CDC 里我设置的这个参数,这个值是否可以超出集群配置去设置呢?

Flink CDC 里我设置的这个参数,启动了大概134个任务会占用270左右的cpu核数,再启动任务就又出现了timeout,这个值是否可以超出集群配置去设置呢? yarn.nodemanager.resource.cpu-vcores 270cpu可以通过这个调整物理和虚拟的占比,内存是不是只能...

Flink CDC产品常见问题之chenckpoint间隔时间设置多久合适

问题一:Flink CDC里再跑又不会报错怎么回事? Flink CDC里A slave with the same server_uuid/server_id as this slave has connected to the master; the first event 'itpuxdb-b...

目前Flink CDC读取pg数据库的表,怎么设置参数提高同步效率,有文档吗?

目前Flink CDC读取pg数据库的表,如果表里面的数据量特别大,怎么设置参数提高同步效率,有文档吗?

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

产品推荐

社区圈子

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

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关