Question

1
Replies
97
Views
Close popover
Vadivel Muthu (VadivelM7950)
Cognizant
Manager
Cognizant
IN
VadivelM7950 Member since 2014 4 posts
Cognizant
Posted: February 20, 2020
Last activity: February 27, 2020
Closed

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 Lead System Architect
Moderation Team has archived post,
Close popover This thread is closed to future replies. Content and links will no longer be updated. If you have the same/similar Question, please write a new Question.