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

Himanshu Gwalani reassigned PHOENIX-7672:
-----------------------------------------

    Assignee: Himanshu Gwalani  (was: Andrew Kyle Purtell)

> ReplicationLogReplay should acquire lease on unclosed file before processing 
> them
> ---------------------------------------------------------------------------------
>
>                 Key: PHOENIX-7672
>                 URL: https://issues.apache.org/jira/browse/PHOENIX-7672
>             Project: Phoenix
>          Issue Type: Sub-task
>            Reporter: Himanshu Gwalani
>            Assignee: Himanshu Gwalani
>            Priority: Major
>             Fix For: PHOENIX-7562-feature
>
>
> As of now, while initializing the ReplicationLogReader, it has optional 
> trailer validation ([code 
> reference|https://github.com/apache/phoenix/blob/295848b44600689c626e404fd7a37e84f3c14d02/phoenix-core-server/src/main/java/org/apache/phoenix/replication/log/LogFileFormatReader.java#L58-L77])
>  and no validation for header (it seeks to the first row, which would throw 
> IOException if header is missing, but not validate if header is as expected 
> or not).
> Also the writer as of now writes header in lazy fashion (i.e. on receiving 
> the first mutation for log file). This can lead to empty (zero length) log 
> files on target cluster if RS does not receive any mutations for log file 
> rotation time (1 min). This would also make it difficult 
> DOD:
> 1. Source writer must add header as soon as the file is created (instead of 
> waiting for new mutation)
> 2. While initializing the ReplicationLogReader, it should validate that file 
> has valid header and trailer
> 3. Another inititilazation method that optionally allows skipping the trailer 
> validation (to deal with scenarios when RS was not able to close the file 
> successfully)
> 4. Throw MissingTrailerException / InvalidTrailerException in case of 
> missing/corrupt trailer (and similar for header, i.e. MissingHeaderException)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to