问答 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.请问有人遇到过类似情况吗

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

在Flink中将流表数据与Hive维表进行JOIN时,数据是如何被分配到对应subtask的?

在Flink中将流表数据与Hive维表进行JOIN时,数据是如何被分配到对应subtask的?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之基于宽表数据展示实时报表,该如何实现

问题一:有flink cep的教程或者demo可以分享一下吗? 有flink cep的教程或者demo可以分享一下吗? 参考答案: 官网文档地址,搜cep 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/586147 问题二:Fli...

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何在外部查询某个job中的表数据

问题一:升级到flink1.17.1 + cdc2.3或更高版本,经常出现无法连接数据帮忙看下是怎么回事呢? 使用flink1.17.1 + cdc2.2.1启动的job没有问题,可以连续启动三四个。但是当升级到flink1.17.1 + cdc2.3或更高版本(比如2.4、2.4.2、3.0)时,经常出现无法连接数据库的问题,而且每次提交到第二个或第三个job基本上就一定会出现复制错误...

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

Flink CDC中oraclecdc监听表数据,表数据触发频率太高的话会漏掉监听吗?

Flink CDC中oraclecdc监听表数据,表数据触发频率太高的话会漏掉监听吗?

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

flink cdc 任务重启,读取新增的表数据不全,没有读取到全量数据

flink cdc 任务MySqlSource.databaseList处理的表为order_1表,现在由于业务迭代需要新增表order_2,这个表order_2在数据库已经存在,我的处理步骤是这样的:先保存了flink任务checkpoint,然后暂停flink任务,修改flink代码,在 MySqlSource.databaseList里增加表order_2,然后基于checkpoint重启....

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

对于Flink CDC,CDC在同步表数据时,出现了两行一模一样的数据,而且时间相隔很近?

对于Flink CDC,CDC在同步表数据时,出现了两行一模一样的数据,而且时间相隔很近,导致第二行出现了唯一冲突。这个问题闻所未闻,所以想请教下有谁有排查方向吗?

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

Flink流对应维表是一对多的关系维表数据是否会都关联上

Flink流对应维表是一对多的关系维表数据是否会都关联上

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

Flink结果表数据量正确性问题

Flink结果表数据量正确性问题

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

Flink cdc source Records Sent比物理表数据量大

Flink cdc source Records Sent比物理表数据量大

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

产品推荐

阿里云实时计算Flink

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

+关注