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

Posted to jira@kafka.apache.org by "Kowshik Prakasam (Jira)" <ji...@apache.org> on 2021/06/16 07:54:00 UTC

[jira] [Updated] (KAFKA-12955) Fix LogLoader to pass materialized list of segments for deletion

     [ 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)