Question

1
Replies
48
Views
VadivelM7950 Member since 2014 4 posts
Cognizant
Posted: 8 months ago
Last activity: 7 months 3 weeks ago

Exception while retrieving data from external kafka using Data Flow

Hi,

Created a Data Set and Configured the Data Flow to retrieve the message from External Kafka Queue. While executing the Data Flow, getting the few records failed with below exception.

$Worker.run(ThreadPoolExecutor.java:624) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:44) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:41) at 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.pega.dsm.dnode.api.ExceptionWithInputRecord: java.util.NoSuchElementException ... 19 more Caused by: java.util.NoSuchElementException at java.util.LinkedList.removeFirst(LinkedList.java:270) at java.util.LinkedList.pop(LinkedList.java:801) at com.pega.dsm.dnode.util.ClipboardPageJsonConverter.adoptJson(ClipboardPageJsonConverter.java:250) at com.pega.dsm.dnode.util.ClipboardPageJsonConverter.adoptJson(ClipboardPageJsonConverter.java:197) at com.pega.dsm.dnode.impl.dataset.kafka.KafkaBrowseOperation.convertRecordToClipboardPage(KafkaBrowseOperation.java:184) at com.pega.dsm.dnode.impl.dataset.kafka.KafkaBrowseOperation.processRecords(KafkaBrowseOperation.java:160) ... 18 more

 

Thanks,

Vadivel M

Pega Platform 7.3 Decision Management Manufacturing and High Technology Lead System Architect
Share this page LinkedIn