问答 2025-01-02 来自:开发者社区

flink cdc source connector 分为 普通cdc版本和sql版本有什么区别?

flink-connector-oracle-cdc、flink-sql-connector-oracle-cdc 都是flink cdc source connector下的。请问这有啥区别呢?一个是基于flink dataStreamApi,一个是基于 flink tableApi吗?

阿里云文档 2024-07-31

Source变更兼容性

本文为您介绍Source变更的可兼容性和不可兼容性详情。

阿里云文档 2024-07-10

SQL变更的其他兼容性限制

本文为您介绍变更SQL除Query、Source和Sink之外的其他限制。

问答 2023-10-25 来自:开发者社区

在Flink需要把source里某个字段加工下得到一个字段,sql该如何写?

在Flink需要把source里某个字段加工下得到一个字段,sql该如何写?source里定义了5个字段,sink里定义了6个字段,

问答 2023-05-23 来自:开发者社区

Flink CDC中怎么让sink并行度和source不一样?flink sql?

Flink CDC中怎么让sink并行度和source不一样?flink sql?

问答 2023-01-09 来自:开发者社区

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-tidb-2.2.0作为sink。想要做全增量一体化数据库同步,出现以下情况 :任务启动后会将数据库存量数据一次性导入,但是增量数据要过20分钟才会开始同步,这是什么原因呢?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注