Support Article

Campaign failing on Strategy stage due to missing DNode

SA-26351

Summary



A campaign has been created with a strategy. The Campaign execution is failing, user reported about missing DNode.

The environment is a Pega 7.1.9 with Page Marketing 7.13.


Error Messages



Error on node [3935baa2c16908a02681592df5836fdd] com.pega.dsm.dnode.api.dataflow.StageException: Exception in stage: TestStrategy
at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageOutputSubscriber.onError(DataFlowStage.java:394)
at com.pega.dsm.dnode.api.dataflow.DataFlowStageProcessor.onError(DataFlowStageProcessor.java:48)
at com.pega.dsm.dnode.impl.dataflow.strategy.StrategyStageProcessor.onNext(StrategyStageProcessor.java:151)
at com.pega.dsm.dnode.api.dataflow.DataFlowStageBatchProcessor.commitBatchInternal(DataFlowStageBatchProcessor.java:102)
at com.pega.dsm.dnode.api.dataflow.DataFlowStageBatchProcessor.commitBatch(DataFlowStageBatchProcessor.java:92)
at com.pega.dsm.dnode.api.dataflow.DataFlowStageBatchProcessor.onCompleted(DataFlowStageBatchProcessor.java:78)
at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onCompleted(DataFlowStage.java:302)
at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor$4.process(DataFlowExecutor.java:213)
at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor.runEventLoop(DataFlowExecutor.java:119)
at com.pega.dsm.dnode.api.dataflow.DataFlow$1.emit(DataFlow.java:162)
at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:56)
at com.pega.dsm.dnode.impl.dataflow.manager.LocalRun.execute(LocalRun.java:145)
at com.pega.dsm.dnode.impl.dataflow.manager.LocalRun.lockAndRun(LocalRun.java:86)
at com.pega.dsm.dnode.impl.dataflow.manager.LocalRun.run(LocalRun.java:63)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:81)

Caused by: com.pega.dsm.dnode.impl.core.ExceptionWithInputRecord: java.lang.IllegalStateException: There are no functional DNodes in the cluster
... 15 more

Caused by: java.lang.IllegalStateException: There are no functional DNodes in the cluster
at com.pega.dsm.dnode.impl.core.RemoteExecutionProxyBuilder.buildProxyToAnyNode(RemoteExecutionProxyBuilder.java:113)
at com.pega.dsm.dnode.api.DNodeContext.getDataRepository(DNodeContext.java:100)
at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraDataSet.getDataRepository(CassandraDataSet.java:18)
at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraSaveOperation$1.get(CassandraSaveOperation.java:51)
at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraSaveOperation$1.get(CassandraSaveOperation.java:48)
at com.google.common.base.Suppliers$ExpiringMemoizingSupplier.get(Suppliers.java:192)
at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraSaveOperation$2.emit(CassandraSaveOperation.java:101)
at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:320)
at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:52)
at com.pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:98)
at com.pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:87)
at com.pega.dsm.dnode.impl.dataflow.strategy.DelayedLearning.saveResultsForDelayedLearning(DelayedLearning.java:53)
at com.pega.dsm.dnode.impl.dataflow.strategy.StrategyStageProcessor.onNext(StrategyStageProcessor.java:145)
... 14 more


Steps to Reproduce



1) Create a omni channel campaign.
2) Associate very simple strategy.
3) Connect proposition to result shape.
4) Schedule run program.
5) Program run failed.


Root Cause



An issue in the custom application code or rules. No D-Nodes were configured. As best practice, when working with data sets and data flows it is important to configure D-Nodes. More specifically, enabling D-Nodes is mandatory when using a "data set" of type "Decision Data Store" or when using "delayed learning" in a strategy shape on "data flow".

Resolution



Navigate to Designer Studio ->Decisioning -> Infrastructure -> DNode Cluster Management -> DNodes.
No DNodes were present, add a DNode and wait for the status to become Online-Normal.

Published August 3, 2016 - Updated August 23, 2017

Have a question? Get answers now.

Visit the Collaboration Center to ask questions, engage in discussions, share ideas, and help others.