Christian Schneider created SLING-13403:
-------------------------------------------
Summary: 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
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)
