Question
Link Group Ltd
AU
Last activity: 17 May 2021 5:53 EDT
Stream service is not enabled error while starting PEGA service
2019-12-16 01:22:38,736 [ions=[10,13,15,17,3]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzStandardProcessor] Preparing retry 29. Next attempt in 2m on data flow [pzStandardProcessor] on stage [InputStage] with affected partitions: [10, 13, 15, 17, 3] com.pega.dsm.dnode.api.StreamServiceException: Stream service is not enabled
Accepted Solution
Pegasystems Inc.
IN
Could you please truncate pr_sys_statusnodes table and re-start the server and check the status of stream services.
Also make sure the provided DSS settings added in each prconfig.xml file with different port for each stream node.
Pegasystems Inc.
IN
Hi,
Please check below link.
https://community.pega.com/support/support-articles/stream-node-unreachable-unable-join
Thanks,
Kranthi
Link Group Ltd
AU
Hi Kranthi,
Apologizes for the delayed response. Can you please provide the exact syntax that can be used to update the prconfig.xml file. We installed PEGA on Windows server
Regards,
Amar
Pegasystems Inc.
IN
Hi ,
Add below DSS setting in prconfig.xml file. Each node should have different open port.
<env name="dsm/services/stream/pyBrokerPort" value="xxxx" /> (default 9092)
Hi ,
Add below DSS setting in prconfig.xml file. Each node should have different open port.
<env name="dsm/services/stream/pyBrokerPort" value="xxxx" /> (default 9092)
<env name="dsm/services/stream/pyKeeperPort" value="xxxx" /> (default 2181)
<env name="dsm/services/stream/pyJmxPort" value="xxxx" /> ( default 9999)
<env name="dsm/services/stream/pyPort" value="xxxx" /> (default 7003)
Thanks,
Kranthi
Pegasystems Inc.
IN
Hi,
Go to stream services landing page and check the status of the node.
It should be normal state. If not please, start or decommission and add it again.
Link Group Ltd
AU
Hi @gundk
Sorry i am new to PEGA, can you please advise how i can access the stream services landing page?
I am seeing this error in admin studio
Error: Stream service is not running in the cluster.
Regards,
Amar
Pegasystems Inc.
IN
Hi,
Dev Studio - > configure ->Decisioning -> infrastructure -> Services -> Stream.
Also refer below link related to this Error.
https://collaborate.pega.com/question/error-stream-service-not-running-cluster
Pegasystems Inc.
IN
Hi Amranath,
The error message shows that the stream service is not up.
Have you added the JVM parameter "-DNodeType=Stream" ?
Please mention which version of Pega you are using and also attach the complete log.
In few versions
Link Group Ltd
AU
Hi Vikash,
Yes, added the stream in jvm.
I already provided the full PEGA_RULES.log, please let me know if you need any other log.
Regards,
Amar
Pegasystems Inc.
IN
I do not see logs attached anywhere in the post.
Could you please attach the complete logs once again.
Link Group Ltd
AU
Hi @gundk
Thanks
I can see four nodes. I deleted the two nodes which are in unreachable state but still can see them (screenshot attached).
Also i tried to start other two nodes but they are not starting up.
Regards,
Amar
Accepted Solution
Pegasystems Inc.
IN
Could you please truncate pr_sys_statusnodes table and re-start the server and check the status of stream services.
Also make sure the provided DSS settings added in each prconfig.xml file with different port for each stream node.
Cigna
US
Hi Kranthi,
We are also seeing lots of exceptions in Logs w.r.t Stream services. I tried this solution but didn't solve the issue. Can you please help.
Please find the exceptions below.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic CYREROUTECONVERSATIONREQUEST. Invalidate topic.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic PYFTSINCREMENTALINDEXER. Invalidate topic.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic PYBATCHINDEXCLASSESPROCESSOR. Invalidate topic.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic PZSTANDARDPROCESSOR. Invalidate topic.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic CYFETCHROUTINGDESTINATION. Invalidate topic
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic CYUPDATECONVERSATIONSCHEMA. Invalidate topic
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic PYPROCESSNOTIFICATION. Invalidate topic.
KafkaRuntimeConfigurationException: Unable to read partition info for validated topic PYBATCHINDEXPROCESSOR. Invalidate topic.
Thanks,
Fathima.
Link Group Ltd
AU
Hi Thanks,
I deleted the nodes and restarted the application and looks like the error has stopped. I will monitor for some more time
Thanks again for your help
Regards,
Amar