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

flink sql 通过doris connector连接doris表时提示读取表数据失败

Caused by: org.apache.doris.flink.exception.DorisException: Load Doris data failed, schema size of fetch data is wrong.请问有人遇到过类似情况吗

问答 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-09-11 来自:开发者社区

Apache Doris Flink Connector 24.0.0 版本正式发布

亲爱的社区伙伴们,Apache Doris Flink Connector 24.0.0 版本已于 2024 年 9 月 5 日正式发布。该版本新增了对 Flink 1.20 的支持,并支持通过 Arrow Flight SQL 高速读取 Doris 中数据。此外,整库同步所依赖的 FlinkCDC,也需升级至 3.1.x 版本࿰...

文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之如何使用Kafka Connector将数据写入到Kafka

问题一:Flink CDC里之前用mysql数据库join比较慢,这种join性能会比较好吗? Flink CDC里之前用mysql数据库join比较慢,所以才改成同步宽表到es,不知道doris,starorcks 这种join性能会比较好吗? 参考答案: Flink CDC 主要用于捕获和处理数据库变更数据流,而不是直接优化JOIN操作。MySQL...

实时计算 Flink版产品使用问题之如何使用Kafka Connector将数据写入到Kafka
问答 2024-08-26 来自:开发者社区

Flink 如何对show create table打印出来的connector参数中的密码加密?

请教一下各位大佬, Flink 如何对show create table tbl_xx 打印出来的connector参数中的密码加密 sql ddl没问题

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

flink1.13版本,自定义实现connector,join流有输入,但是没有输出,怎么解决?

flink1.13版本,自定义实现connector,想在我的数据传输链路用上flink的transformer能力,我在实验双流join时,遇到了表数据量少时,比如3 5条数据,通过webui可以看到,join流有输入,但是没有输出,这是我的connector漏了什么东西没实现吗,还是少配置了一些参数。两张数据量大的表没有这个问题。

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

Flink CDC OceanBase Connector 分为哪几类 ?

Flink CDC OceanBase Connector 分为哪几类 SourceFunction?

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

Flink CDC OceanBase Connector 是如何实现数据增量的拉取的?

Flink CDC OceanBase Connector 是如何实现数据增量的拉取的?

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

Flink CDC OceanBase Connector 开源后的易用性和稳定性如何?

Flink CDC OceanBase Connector 开源后的易用性和稳定性如何?

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

如何提高 Flink CDC OceanBase Connector 的代码质量?

如何提高 Flink CDC OceanBase Connector 的代码质量?

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

产品推荐

实时计算 Flink

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

+关注