问答 2024-07-10 来自:开发者社区

flink cdc transforme 修改字段别名怎么办?

flink cdc transforme 修改字段别名,createtableevent,会出现错误,传给calcite 列信息不对,包找不到id?schema event 是否要再进入TransformDataOperator

阿里云文档 2024-06-28

社区CDC

本文为您介绍如何在阿里云实时计算Flink版中使用社区版CDC(Change Data Capture)连接器,以及更改连接器名称。

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

Flink CDC 这些之前的文章,一个都访问不了了怎么办?

Flink CDC 基于 Flink CDC 3.0 构建 MySQL 到 Doris 的 Streaming ELT 这些之前的文章,一个都访问不了了?https://ververica.github.io/flink-cdc-connectors/release-3.0/content/%E5%BF%AB%E9%80%9F%E4%B8%8A%E6%89%8B/mysql-doris-pipe....

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

Flink CDC里这个怎么办?

'scan.incremental.snapshot.chunk.key-column' must be set when the table doesn't have primary keys.Flink CDC里这个怎么办?应该是有一些没有主键的表,但是我们业务也需要把它同步过来。请问下如何设置分拆的键字段?在哪儿设置?有参考文档吗?

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

Flink CDC里这个错误怎么办?

Flink CDC里这个错误怎么办?

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

Flink CDC里这种错误怎么办?

Flink CDC里这种错误怎么办?2024-04-01 17:02:43,377 ERROR io.debezium.pipeline.ErrorHandler [] - Producer failureio.debezium.DebeziumException: Failed to deserialize data of EventHea...

问答 2024-03-25 来自:开发者社区

Flink CDC里这种错误怎么办?

Flink CDC里这种错误怎么办?4:27:13.899 [flink-akka.actor.default-dispatcher-5] ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler - Exception occurred in REST handler: Job ec49d3a9b1ef8f168055b....

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

Flink CDC里我写了一个look up hint 没有生效,怎么办?

Flink CDC里我写了一个look up hint 没有生效,,flink 版本1.16 ,不知道啥原因?

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

Flink CDC一直是这样怎么办?

Flink CDC一直是这样怎么办?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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