You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@sling.apache.org by "Timothee Maret (Jira)" <ji...@apache.org> on 2021/06/26 21:44:00 UTC
[jira] [Assigned] (SLING-10563) DistributionPublisher closes the
PubQueueProvider service
[ https://issues.apache.org/jira/browse/SLING-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothee Maret reassigned SLING-10563:
--------------------------------------
Assignee: Timothee Maret
> DistributionPublisher closes the PubQueueProvider service
> ---------------------------------------------------------
>
> Key: SLING-10563
> URL: https://issues.apache.org/jira/browse/SLING-10563
> Project: Sling
> Issue Type: Bug
> Components: Content Distribution
> Reporter: Timothee Maret
> Assignee: Timothee Maret
> Priority: Major
> Fix For: Content Distribution Journal Core 0.1.18
>
>
> The PubQueueProvider service is registered via the PubQueueProviderPublisher component. The DistributionPublisher references the PubQueueProvider service and close it when deactivating.
> So, when the DistributionPublisher is active again, it references a closed PubQueueProvider service. As the PubQueueProvider is closed, the PubQueueCache#tailPoller is closed and thus newer package messages are no longer fetched. As a result, distributing new content throws exceptions like the following
> {code}
> [sling-threadpool-950ecf5e-b8e8-4755-9066-918485528372-(apache-sling-job-thread-pool)-5-<main queue>(file_importer_job)] com.day.cq.replication.impl.ReplicatorImpl Error during replication with agent=publish
> com.day.cq.replication.ReplicationException: org.apache.sling.distribution.common.DistributionException: Failed to append distribution package PackageMessage(pubSlingId=4be0493c-b52c-4558-9b68-813843cc4e18, reqType=ADD, pkgId=dstrpck-1623937501721-346c09c9-dcbf-44fe-856e-d5f96148b2a4, pkgType=journal_filevault, pkgLength=9848, pubAgentName=publish, userId=replication-service, paths=[/content/dam/enel-common/updated-files/com/enelChile.xml], deepPaths=[]) to the journal
> at com.adobe.granite.distribution.core.impl.replication.DistributionTransportHandler.deliver(DistributionTransportHandler.java:134) [com.adobe.granite.distribution.core:0.2.56]
> at com.adobe.granite.distribution.core.impl.replication.adapters.ReplicationAgent.replicate(ReplicationAgent.java:116) [com.adobe.granite.distribution.core:0.2.56]
> at com.day.cq.replication.impl.ReplicatorImpl.replicate(ReplicatorImpl.java:451) [com.day.cq.cq-replication:6.3.22]
> at dh.com.common.core.utils.AssetUtils.writeToDam(AssetUtils.java:170) [enel-common.core:1.0.2.2021_0616_1125947_0000485816]
> at dh.com.common.core.schedulers.consumer.FileImporterJobConsumer.process(FileImporterJobConsumer.java:57) [enel-common.core:1.0.2.2021_0616_1125947_0000485816]
> at org.apache.sling.event.impl.jobs.JobConsumerManager$JobConsumerWrapper.process(JobConsumerManager.java:502) [org.apache.sling.event:4.2.12]
> at org.apache.sling.event.impl.jobs.queues.JobQueueImpl.startJob(JobQueueImpl.java:293) [org.apache.sling.event:4.2.12]
> at org.apache.sling.event.impl.jobs.queues.JobQueueImpl.access$100(JobQueueImpl.java:60) [org.apache.sling.event:4.2.12]
> at org.apache.sling.event.impl.jobs.queues.JobQueueImpl$1.run(JobQueueImpl.java:229) [org.apache.sling.event:4.2.12]
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: org.apache.sling.distribution.common.DistributionException: Failed to append distribution package PackageMessage(pubSlingId=4be0493c-b52c-4558-9b68-813843cc4e18, reqType=ADD, pkgId=dstrpck-1623937501721-346c09c9-dcbf-44fe-856e-d5f96148b2a4, pkgType=journal_filevault, pkgLength=9848, pubAgentName=publish, userId=replication-service, paths=[/content/dam/enel-common/updated-files/com/enelChile.xml], deepPaths=[]) to the journal
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.execute(DistributionPublisher.java:291) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.execute(DistributionPublisher.java:258) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> at com.adobe.granite.distribution.core.impl.replication.adapters.ReplicationAgent$1.distribute(ReplicationAgent.java:120) [com.adobe.granite.distribution.core:0.2.56]
> at com.adobe.granite.distribution.core.impl.replication.DistributionTransportHandler.deliver(DistributionTransportHandler.java:124) [com.adobe.granite.distribution.core:0.2.56]
> ... 11 common frames omitted
> Caused by: java.lang.RuntimeException: java.util.concurrent.TimeoutException
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.sendAndWait(DistributionPublisher.java:309) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.lambda$execute$2(DistributionPublisher.java:278) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> at org.apache.sling.distribution.journal.shared.DistributionMetricsService.timed(DistributionMetricsService.java:131) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.execute(DistributionPublisher.java:278) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> ... 14 common frames omitted
> Caused by: java.util.concurrent.TimeoutException: null
> at java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
> at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
> at org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher.sendAndWait(DistributionPublisher.java:306) [org.apache.sling.distribution.journal:0.1.17.T202103231434-787e79f]
> ... 17 common frames omitted
> {code}
> and distribution actions sent by other instances are no longer reflected in the queue.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)