[
https://issues.apache.org/jira/browse/SLING-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Schneider reassigned SLING-13403:
-------------------------------------------
Assignee: Christian Schneider
> Wait boundedly for in-flight journal imports during subscriber deactivation
> ---------------------------------------------------------------------------
>
> Key: SLING-13403
> URL: https://issues.apache.org/jira/browse/SLING-13403
> Project: Sling
> Issue Type: Bug
> Components: Content Distribution
> Reporter: Christian Schneider
> Assignee: Christian Schneider
> Priority: Major
>
> DistributionSubscriber.deactivate() stops polling but does not wait for a
> package already being processed. If the subscriber is reactivated before that
> import commits its offset, the replacement can load the same offset and
> import the package concurrently.
> Wake pending retry back-offs during deactivation and wait up to 30 seconds
> for the current package handler to finish. Do not interrupt the import thread
> or introduce locking between subscriber instances. Log a warning if the wait
> expires.
> The wait is best-effort: imports exceeding the timeout can still overlap, and
> it does not coordinate leadership handover between nodes.
> Add regression coverage for waiting for an active handler, a bounded timeout,
> and promptly waking a retry back-off.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
