Question

Registers of Scotland
GB
Last activity: 5 Jun 2020 8:57 EDT
decommissioning a stream server
We have an environment that previously had 4 stream servers. But now only 1. We would like to decommission 3 of the servers.
When we try the Decommission action from the Stream admin page nothing happens in the UI and in the logs we get...
We have an environment that previously had 4 stream servers. But now only 1. We would like to decommission 3 of the servers.
When we try the Decommission action from the Stream admin page nothing happens in the UI and in the logs we get...
2020-06-05 11:56:16,875 [ PegaRULES-Batch-4] [ STANDARD] [ ] [RegistrationFW:02.99] (ernal.async.BatchRequestorTask) ERROR XXXX - Batch activity "Embed-Decision-Service-Operation.pzAsyncExecuteOperation" threw:
com.pega.pegarules.pub.PRRuntimeError: PRRuntimeError
at com.pega.pegarules.session.internal.mgmt.base.ThreadRunner.runActivitiesAlt(ThreadRunner.java:721) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.mgmt.base.ThreadRunner.runActivities(ThreadRunner.java:580) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.mgmt.PRThreadImpl.runActivities(PRThreadImpl.java:511) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.async.agent.QueueProcessor.executeBatchTask(QueueProcessor.java:304) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.async.agent.QueueProcessor.execute(QueueProcessor.java:371) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.async.BatchRequestorTask.run(BatchRequestorTask.java:1158) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.PRSessionProviderImpl.performTargetActionWithLock(PRSessionProviderImpl.java:1397) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.PRSessionProviderImpl.doWithRequestorLocked(PRSessionProviderImpl.java:1140) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.PRSessionProviderImpl.doWithRequestorLocked(PRSessionProviderImpl.java:1021) ~[prprivate-session.jar:?]
at com.pega.pegarules.session.internal.async.BatchRequestorTask.run(BatchRequestorTask.java:818) ~[prprivate-session.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_252]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_252]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]
Caused by: com.pega.dsm.dnode.api.StreamServiceException: Unable to execute reassignment, brokers 1002, 1004 are offline
at com.pega.dsm.kafka.scale.service.StreamUtilServiceImpl.executeReassignment(StreamUtilServiceImpl.java:183) ~[d-node.jar:?]
at com.pega.dsm.kafka.scale.service.StreamUtilServiceImpl.executeReassignmentExcludingBroker(StreamUtilServiceImpl.java:174) ~[d-node.jar:?]
at com.pega.dsm.dnode.api.server.StreamServerService$StreamServiceDecommissionOperation$2$1.execute(StreamServerService.java:891) ~[d-node.jar:?]
Is there another way that we can remove the Stream nodes? Maybe a table we can update?
thanks,