[
https://issues.apache.org/jira/browse/HUDI-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910533#comment-17910533
]
Danny Chen commented on HUDI-8799:
----------------------------------
The RFC declaration PR is merged via master:
36176614a7b1e28705a5b56ccfefda05cb5fbfb4
> [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)
