hudi继承flink
时间: 2023-09-11 13:10:02 浏览: 133
Hudi与Flink之间的兼容性存在一些问题。根据引用,自Hudi 0.8.0版本开始,它可以与Flink 1.12.x及以上版本兼容,并支持通过Flink写入数据到Hudi。但需要注意的是,在写入过程中必须开启checkpoint,并且至少有5次checkpoint完成后才能看到对应Hudi中的数据。
此外,根据引用,在本地执行Flink代码向Flink写入数据时可能会出现一些错误,如"java.lang.AbstractMethodError"和"HoodieException: Get table avro schema error"。这些错误可能是由于Hudi版本支持问题导致的。
综上所述,Hudi可以与Flink配合使用,但需要确保Hudi和Flink的版本兼容,并注意必要的配置和错误处理。同时,也建议查阅相关文档或博客以获取更详细的信息和解决方案。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [数据湖(六):Hudi与Flink整合](https://blog.csdn.net/xiaoweite1/article/details/125107451)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]
阅读全文