Skip to main content

This content is closed to future replies and is no longer being maintained or updated.
Links may no longer function. If you have a similar request, please write a new post.

Question

 Santo Quattrone (SantoQ17)
Reply s.p.a.
IT Consultant
Reply s.p.a.
IT
SantoQ17 Member since 2013 4 posts
Reply s.p.a.
Posted: Jul 2, 2021
Last activity: Dec 1, 2021
Posted: 2 Jul 2021 4:22 EDT
Last activity: 1 Dec 2021 1:22 EST
Closed

Personal Edition 8.6 errors

Hi all,

Show More

Hi all,

after download and install my PE 8.6, after a few minutes from startup it stats to log  this error in a very verbouse way: <pxException>com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSubscriberException: [QueueProcessor: pyFTSIncrementalIndexer] [MessageID: 68d1abdf-bd14-4ad3-b116-3fe45305d0a3] Failed to save message in kafka. Original exception message: null         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSubscriber.lambda$onNext$0(QueueProcessorDataSubscriber.java:55)         at java.util.Optional.map(Optional.java:215)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSubscriber.onNext(QueueProcessorDataSubscriber.java:55)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSubscriber.onNext(QueueProcessorDataSubscriber.java:32)         at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.onNext(DataObservableImpl.java:305)         at com.pega.dsm.dnode.impl.dataset.stream.StreamSaveOperation.save(StreamSaveOperation.java:115)         at com.pega.dsm.dnode.impl.dataset.stream.StreamSaveOperation.doSave(StreamSaveOperation.java:99)         at com.pega.dsm.dnode.impl.dataset.stream.StreamSaveOperation.lambda$null$0(StreamSaveOperation.java:92)         at com.pega.dsm.dnode.impl.dataset.kafka.metrics.KafkaSaveMetrics.timeSave(KafkaSaveMetrics.java:85)         at com.pega.dsm.dnode.impl.dataset.stream.StreamSaveOperation.lambda$save$1(StreamSaveOperation.java:92)         at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:353)         at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:55)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSetOperationsImpl.saveToDataSet(QueueProcessorDataSetOperationsImpl.java:187)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataSetOperationsImpl.queueToDataSet(QueueProcessorDataSetOperationsImpl.java:156)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.DelayedItemsProcessor.queueToDataSet(DelayedItemsProcessor.java:72)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.DelayedItemsProcessor.process(DelayedItemsProcessor.java:59)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.DelayedItemsDataFlowFactory$DelayedItemsStageProcessor.onNext(DelayedItemsDataFlowFactory.java:190)         at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.DelayedItemsDataFlowFactory$DelayedItemsStageProcessor.onNext(DelayedItemsDataFlowFactory.java:177)         at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onNext(DataFlowStage.java:478)         at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onNext(DataFlowStage.java:405)         at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor$2.process(DataFlowExecutor.java:327)         at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor.runEventLoop(DataFlowExecutor.java:218)         at com.pega.dsm.dnode.api.dataflow.DataFlow$2.emit(DataFlow.java:331)         at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:59)         at com.pega.dsm.dnode.impl.dataflow.task.strategy.ExecutionStrategy.executeDataFlow(ExecutionStrategy.java:124)         at com.pega.dsm.dnode.impl.dataflow.task.strategy.MultiplePartitionExecution.executePartitions(MultiplePartitionExecution.java:87)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.executeDataFlowWithPartitions(ExecutePartitionsRunnable.java:86)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.access$900(ExecutePartitionsRunnable.java:34)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable$1.run(ExecutePartitionsRunnable.java:67)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable$1.run(ExecutePartitionsRunnable.java:62)         at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)         at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContextInternal(ServiceHelper.java:301)         at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContext(ServiceHelper.java:146)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.call(ExecutePartitionsRunnable.java:62)         at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.call(ExecutePartitionsRunnable.java:34)         at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108)         at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)         at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:77)         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)         at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:59)         at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:56)         at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)         at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:124) Caused by: java.lang.InterruptedException         at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)         at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)         at com.pega.dsm.dnode.impl.dataset.stream.StreamServicePublisherFeature.getPublisher(StreamServicePublisherFeature.java:49)         at com.pega.dsm.dnode.impl.dataset.stream.StreamSaveOperation.save(StreamSaveOperation.java:109)         ... 38 more

 

 

anyone of you has experienced this kind of issue yet?  thank you so much

 

 

Show Less
***Edited by Moderator: Pooja Gadige to add platform capability tag***
To see attachments, please log in.
Pega Platform 8.6
Case Management
Installation and Deployment
Lead System Architect

Posted: 3 years ago
Posted: 15 Nov 2021 4:28 EST
Manish Verma (Manish Verma)
UBS

UBS
IN

Hello @SantoQ17,

We are seeing similar issue in the "BackgroundProcessing" node on 8.6.1. Were you able to resolve this issue? If yes, highly appreciate if you could you share the solution please?

Warm Regards,

Manish Verma

 

To see attachments, please log in.
Posted: 3 years ago
Updated: 3 years ago
Posted: 30 Nov 2021 9:31 EST
Updated: 1 Dec 2021 1:22 EST
Rahul Gamini (Rahul G)
Quest Diagnostics HTAS
Rahul Gamini
Quest Diagnostics HTAS
IN

@SantoQ17

 

I faced the same issue in 8.6.2 and I am using external elastic search in my local, assuming the same is the case with you.

 

Resolution which worked for me:

1) Stop the pega server 

2) truncate below tables 

pr_sys_statusnodes

pr_data_stream_nodes

pr_data_stream_node_updates

pr_data_stream_sessions

3) Delete below Directories:

kafka-data

kafka-1.1.0.x

4) Restart the VM

5) Start the elastic search server 

3) Start the pega server or cluster nodes one by one.

 

Note: Start the pega server only after the elastic search server is started

 

Thanks,

Rahul.

To see attachments, please log in.

We'd prefer it if you saw us at our best.

Pega Collaboration Center has detected you are using a browser which may prevent you from experiencing the site as intended. To improve your experience, please update your browser.

Close Deprecation Notice