Support Article
UnknownServerException occurs at destination in a dataflow
Summary
A real time dataflow is present with a Stream dataset as the source and a dataflow as the destination which in turn writes to a Stream dataset. Errors occur at the destination.
Error Messages
pega.dsm.dnode.api.ExceptionWithInputRecord: org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation.failSingleRecord(KafkaSaveOperation.java:278)at pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation.save(KafkaSaveOperation.java:144)at pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation.access$600(KafkaSaveOperation.java:49)at pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation$1.emit(KafkaSaveOperation.java:134)at pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:338)at pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:40)at pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:102)at pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:91)at pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onPulse(DataFlowStage.java:418)at pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor.runEventLoop(DataFlowExecutor.java:206)at pega.dsm.dnode.api.dataflow.DataFlow$2.emit(DataFlow.java:312)at pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:44)at pega.dsm.dnode.impl.dataflow.task.strategy.ExecutionStrategy.executeDataFlow(ExecutionStrategy.java:97)at
Steps to Reproduce
Run a real time dataflow.
Root Cause
A defect in Pegasystems’ code or rules.
Resolution
Perform the following local-change:
Increase the Retention period of the Stream dataset from 30 minutes to 12 hours.
Published August 19, 2019 - Updated December 2, 2021
Have a question? Get answers now.
Visit the Collaboration Center to ask questions, engage in discussions, share ideas, and help others.