Support Article
Cassandra error occurs when running a 20M Campaign
Summary
User is running a Campaign and it is failing.
A Campaign fails when it is run. The DataFlow run fails while reading from the Cassandra dataset.
Error Messages
com.pega.dsm.dnode.api.dataflow.StageException: Exception in stage: FCA at com.pega.dsm.dnode.api.dataflow.StageException.create(StageException.java:34) at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageOutputSubscriber.onError(DataFlowStage.java:474) at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onError(DataFlowStage.java:342) at j com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:52) at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:109) Caused by: com.datastax.driver.core.exceptions.OperationTimedOutException: Timed out waiting for server response at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:44) at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:26) at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245) at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68) at com.pega.dsm.dnode.impl.dataset.cassandra.SessionProxy.execute(SessionProxy.java:117) at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraBrowseByPartitionOperation$2.emit(CassandraBrowseByPartitionOperation.java:96) at com.pega.dsm.dnode.impl.dataset.cassandra.CassandraDataEmitter.emit(CassandraDataEmitter.java:54) at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:335) ... 18 more Caused by: com.datastax.driver.core.exceptions.OperationTimedOutException: Timed out waiting for server response at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onTimeout(RequestHandler.java:770) at com.datastax.driver.core.Connection$ResponseHandler$1.run(Connection.java:1374) at io.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:581) at io.netty.util.HashedWheelTimer$HashedWheelBucket.expireTimeouts(HashedWheelTimer.java:655) at io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:367)
Steps to Reproduce
Run a 20M Campaign.
Root Cause
A defect in Pegasystems’ code or rules.
Resolution
Apply HFix-51140.
Published April 9, 2019 - Updated October 8, 2020
Have a question? Get answers now.
Visit the Collaboration Center to ask questions, engage in discussions, share ideas, and help others.