阿里云文档 2025-12-29

hudi连接器

本文为您介绍如何使用Hudi连接器。

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

flink cdc 读取mysql数据写入hudi表中,为什么出现这种情况?

flink cdc 读取mysql数据写入hudi表中,再用flinksql查询hudi表数据写入另一个hudi表中,源表数据删除,第一个hudi表中数据成功删除,第二个hudi表中数据没有删除。有大神知道怎么回事吗?

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

Flink CDC现在mysql cdc 到hudi 出现了连接超时了?

Flink CDC现在mysql cdc 到hudi 出现了连接超时了?

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

使用flink cdc 读取mysql中的数据写入hudi中,知道是为什么吗?

使用flink cdc 读取mysql中的数据写入hudi中,但是最后一批数据不会写入ro表,只有等我再次添加数据或者修改数据的时候才会同步到ro表,有大佬知道是为什么吗?https://github.com/apache/hudi/issues/6019类似与这个问题

问答 2023-07-19 来自:开发者社区

flink cdc 整库同步MySQL 如何写入hudi,sink hudi的代码该如何写?

flink cdc 整库同步MySQL 如何写入hudi,sink hudi的代码该如何写?

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

各位大神 ,我用flink cdc 采集mysql,写入hudi 发现checkpoint设置?

各位大神 ,我用flink cdc 采集mysql,写入hudi 发现checkpoint设置的时间如果过长导致 flink cdc 采集的延迟特别大 有大神遇到过这样的问题吗?

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

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时差多了八个小时,当时让我看MySQL的时区是Asia/Shanghai (CST,+0800)? 就是有个问题是,我这边有两个业务库,时区都是一样的,只有这个同步过来时区+8小时,另外的那个是正常的,这个是什么原因?我这样加 不对,正确的如何加呀?

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

大佬 我flink cdc实时同步MySQL表的时间到了我hudi平台多了八小时,这个是不是时区设置

大佬 我flink cdc实时同步MySQL表的时间到了我hudi平台多了八小时,这个是不是时区设置的问题?读了出来 就是0时区的时间戳,存到parquet也是,用hive读是多8小时,用flink读是正常的,不是 我这边是sink hudi查看是多了八个小时

问答 2023-02-19 来自:开发者社区

flink cdc程序在挂了以后这段时间mysql删除数据在hudi不能同步嘛?

flink cdc程序在挂了以后这段时间mysql删除数据在hudi不能同步嘛?如果有怎么同步在hudi删除啊?设置了backend和checkpoint

问答 2022-08-09 来自:开发者社区

请问一个问题,数据通过flink cdc读mysql写入ods层的hudi表,然后再将事实表和维度表

请问一个问题,数据通过flink cdc读mysql写入ods层的hudi表,然后再将事实表和维度表合并写入dwd层的hudi表。我发现ods层的数据量是对的,dwd层一开始新增数据时,数据量是对的,但维表有变更时,mor表数据量变少了、cow表数据量是对的。请问这个mor表数据量少的问题应该怎么排查呢?谢谢

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

产品推荐

阿里云实时计算Flink

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

+关注