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

Kowshik Prakasam updated KAFKA-12955:
-------------------------------------
    Description: Within {{LogLoader.removeAndDeleteSegmentsAsync()}}, we should 
force materialization of the {{segmentsToDelete}} iterable, to make sure the 
results of the iteration remain valid and deterministic. We should also pass 
only the materialized view to the logic that deletes the segments. Otherwise, 
we could end up deleting the wrong segments asynchronously.  (was: Within 
{{LogLoader.removeAndDeleteSegmentsAsync()}}, we should force materialization 
of the {{segmentsToDelete}} iterable, to make sure the results of the iteration 
remain valid and deterministic. We should also pass only the materialized view 
to the logic that deletes the segments.)

> Fix LogLoader to pass materialized list of segments for deletion
> ----------------------------------------------------------------
>
>                 Key: KAFKA-12955
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12955
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Kowshik Prakasam
>            Priority: Critical
>
> Within {{LogLoader.removeAndDeleteSegmentsAsync()}}, we should force 
> materialization of the {{segmentsToDelete}} iterable, to make sure the 
> results of the iteration remain valid and deterministic. We should also pass 
> only the materialized view to the logic that deletes the segments. Otherwise, 
> we could end up deleting the wrong segments asynchronously.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to