问答 2024-05-01 来自:开发者社区

Flink CDC里yaml 的方式 可以正则配置 多个库的多个表吗?

flink-cdc-3.0.0 配置的yaml任务,我想提交到yarn集群上执行,不过每次启动需要在flink-conf 配置rest.bind-port: {{REST_PORT}}rest.address: {{NODE_IP}}execution.target: yarn-sessionyarn.application.id: {{YARN_APPLICATION_ID}} ,/bin/.....

问答 2024-05-01 来自:开发者社区

flink 1.18 cdc 配置了 MySQL同步到Doris, source配置什么啊?

flink 1.18 cdc 配置了 MySQL同步到Doris, source配置了 tables: test..* ,MySQL有新增表的话但是Doris里面没有创建,重启CDC任务就可以?如果MySQL某个数据库下面每天都会新增一张表 这个有啥好的处理方式吗?目前通过cdc yaml 配置的方式应该没有这个参数吧?

问答 2024-05-01 来自:开发者社区

Flink CDC里阿里云的oss作为flink的状态后端配置,有大佬知道怎么用吗?

Flink CDC里阿里云的oss作为flink的状态后端配置,有大佬知道怎么用吗?state.backend: rocksdbstate.checkpoints.dir: oss://your-bucket/flink/checkpointsfs.oss.accessKeyId: your-access-key-idfs.oss.accessKeySecret: your-access-key....

问答 2024-04-29 来自:开发者社区

flink cdc 配置了 MySQL同步到Doris, 这个是有啥参数配置吗?

flink cdc 配置了 MySQL同步到Doris, source配置了 tables: test..* ,MySQL有新增表的话但是Doris里面没有创建,重启CDC任务就可以?这个是有啥参数配置吗?

问答 2024-04-26 来自:开发者社区

Flink CDC里大佬们知道oraclecdc时可以配置什么让他的速率快点?

大佬们知道oraclecdc可以配置什么让他的速率快点吗?感觉几万条数据,增量一下就写进了,全量得很久.

问答 2024-04-22 来自:开发者社区

pg 开启 flink cdc 时,下面两个参数 必须一致吗,最大能配置多少,有大佬知道吗?

pg 开启 flink cdc 时,下面两个参数 必须一致吗,最大能配置多少,有大佬知道吗max_replication_slotsmax_wal_senders

问答 2024-04-22 来自:开发者社区

flink cdc这个配置 io.tmp.dirs 的目录怎么越来越大,怎么设置它的大小啊?

flink cdc这个配置 io.tmp.dirs 的目录怎么越来越大,直接把目录占满了,怎么设置下他的大小或者清理策略啊?

问答 2024-04-15 来自:开发者社区

使用Flink CDC 同步MySQl。配置了多张表, 有一张A表删除了字段,然后停止同步后怎么做?

使用Flink CDC 同步MySQl。配置了多张表, 有一张A表删除了字段,然后停止同步,将A表移除同步队列,过了一段时间之后将A表加回去,但是读取Schema的时候还是可以读取到已经删除的字段,导致报错和实际字段数量不一致,这种情况要怎么处理?消费点位是和单张表绑定的么?

问答 2024-04-15 来自:开发者社区

Flink CDC里我有张mysql表,配置的是init,每次都是同步一条数据,然后就不同步了为啥?

Flink CDC里我有张mysql表,配置的是init,试了好几次,每次都是同步一条数据,然后就不继续同步数据了,可能是啥原因?

问答 2024-04-15 来自:开发者社区

Flink CDC里实时这块搭建的集群配置要求有参考的嘛?

Flink CDC里实时这块搭建的集群配置要求有参考的嘛?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注