问答 2023-11-30 来自:开发者社区

Flink CDC中sqlserver里面,源头数据库更新数据之后,吐出来的op是u,还是先d后c?

Flink CDC中sqlserver里面,源头数据库更新数据之后,吐出来的op是u,还是先d后c?

问答 2023-11-30 来自:开发者社区

Flink CDC中oracle cdc 如何同步blob或者clob类型的数据呢?

Flink CDC中oracle cdc 如何同步blob或者clob类型的数据呢,我看debezium文档需要开启lob.enable=true,但是开启后就会报错,有没有大佬解决过的?

问答 2023-11-30 来自:开发者社区

Flink CDC这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了?

Flink CDC这看着是有数据进来的,这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了?

文章 2023-11-28 来自:开发者社区

由于Flink CDC在同步MySQL数据时,没有正确地处理并行度和server-id导致的

这个问题可能是由于Flink CDC在同步MySQL数据时,没有正确地处理并行度和server-id导致的。为了解决这个问题,你可以尝试以下方法: 检查你的Flink CDC配置,确保你正确地设置了server-id和并行度。你可以在Flink CDC的配置文件中设置这些参数,例如: jobmanager.rpc...

文章 2023-11-23 来自:开发者社区

Flink CDC读取kafka中的数据,发现读出来数据都是都是null

遇到读取 Kafka 数据都为空的情况,请检查以下几个方面: Kafka topic 是否正确配置,确保 topic 名称、消费者组和其他属性正确无误。Kafka topic 内容是否存在有效数据。配置连接和 consumer 参数是否正确,例如 hostname、port 等。使用调试工具检查 Kafka producer 端࿰...

问答 2023-11-22 来自:开发者社区

Flink CDC 我flink 读取kafka数据然后入库到starrocks不知道问题出在哪了?

Flink CDC 各位我flink 读取kafka数据然后入库到starrocksCREATE TABLE mall_activity ( id bigint, create_time TIMESTAMP, create_by bigint, create_by_name ...

问答 2023-11-22 来自:开发者社区

Flink CDC同步MySQL数据又出现了把我们从库给搞宕机的情况。不知道为什么还是会产生那么多?

Flink CDC同步MySQL数据又出现了把我们从库给搞宕机的情况。我们指定了一个server-id,并行度也只给了一个ie,但是不知道为什么还是会产生那么多master-thread-id ?

问答 2023-11-22 来自:开发者社区

Flink CDC启动后仍然从头开始读取数据,有没有遇到过呢 ?

Flink CDC用tidb连接器flink-connector-tidb-cdc-2.4.1.jar遇到从已存在的ck启动无效问题,启动后仍然从头开始读取数据,有没有遇到过呢 ?

问答 2023-11-22 来自:开发者社区

您好,flink cdc请教一个问题,同步oracle的数据报错,使用配置如下:?

您好,请教一个问题,同步oracle的数据报错,使用配置如下:cdc版本:flink-sql-connector-oracle-cdc-2.3-SNAPSHOT.jar:2.3-SNAPSHOT驱动版本:ojdbc8-23.2.0.0.jarOracle 版本: Oracle Database 11g Enterprise Edition Release 11.2.0.4.0 - 64bit P....

问答 2023-11-22 来自:开发者社区

我直接用Flink CDC代码消费kafka数据没问题,大家有遇到过这种问题不?

我直接用Flink CDC代码消费kafka数据没问题,但是用flinksql消费kafka数报警告,大家有遇到过这种问题不?2023-11-17 09:45:39 WARN (org.apache.kafka.clients.consumer.ConsumerConfig:logUnused) - The configuration 'partition.discovery.int...

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等