You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "sivabalan narayanan (Jira)" <ji...@apache.org> on 2022/01/18 11:59:00 UTC

[jira] [Assigned] (HUDI-3265) Implement a custom serializer for the WriteStatus

     [ https://issues.apache.org/jira/browse/HUDI-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

sivabalan narayanan reassigned HUDI-3265:
-----------------------------------------

    Assignee: Gary Li

> Implement a custom serializer for the WriteStatus
> -------------------------------------------------
>
>                 Key: HUDI-3265
>                 URL: https://issues.apache.org/jira/browse/HUDI-3265
>             Project: Apache Hudi
>          Issue Type: Task
>          Components: flink
>            Reporter: sivabalan narayanan
>            Assignee: Gary Li
>            Priority: Major
>              Labels: sev:normal
>
> When the structure of WriteStatus changed, and when we restart the Flink job with the new version, the job will fail to recover.
> *To Reproduce*
> Steps to reproduce the behavior:
>  # Start a flink job.
>  # Changed the WriteStatus and restart
>  # The job can't recover.
> We need to implement a custom serializer for the WriteStatus.
>  
> Ref issue: [https://github.com/apache/hudi/issues/4032]
>  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)