[
https://issues.apache.org/jira/browse/HUDI-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Geser Dugarov closed HUDI-8799.
-------------------------------
Resolution: Fixed
RFC design is merged into master, commit
c561bde64a11fb26b9e22a929cd7ac955932f7f4.
> [RFC-84] Optimized SerDe of `DataStream` in Flink operators
> -----------------------------------------------------------
>
> Key: HUDI-8799
> URL: https://issues.apache.org/jira/browse/HUDI-8799
> Project: Apache Hudi
> Issue Type: New Feature
> Reporter: Geser Dugarov
> Assignee: Geser Dugarov
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.1.0
>
>
> Currently for Flink stream write, we convert Flink {{RowData}} to
> {{HoodieRecord}} first, and then {{HoodieRecord}} is serialized and
> deserialized using Kryo. This SerDe costs are high, which leads to slower
> `DataStream` processing. Using Flink's internal serialization instead of Kryo
> could decrease processing time of each record in stream significantly.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
