Issue with peerclassloading when using dataStreamers

classic Classic list List threaded Threaded
2 messages Options
gupabhi gupabhi
Reply | Threaded
Open this post in threaded view
|

Issue with peerclassloading when using dataStreamers

I'm using datastreamers to ingest data from files into the cache. I've a need to do an 'upsertion' to the data being ingested, therefore I'm using streamReceiver too.

See attached java class and log snippet. When we run the code calling addData on the datastreamer after a while, we start seeing exceptions being thrown. But this doesn't happen always. I.e. Peerclassloading seems to work at times and not at others with no code change. It seems like there is a race.

Any suggestions on what might be happening or is there a better, more reliable way to do this?


Thanks,
Abhishek


StreamReceiver-Log.txt (5K) Download Attachment
CassStreamReceiverPeerLoading.java (2K) Download Attachment
ilya.kasnacheev ilya.kasnacheev
Reply | Threaded
Open this post in threaded view
|

Re: Issue with peerclassloading when using dataStreamers

Hello!

Can you please share complete logs from all nodes in your cluster?

Regards,
--
Ilya Kasnacheev


чт, 9 мая 2019 г. в 18:00, Abhishek Gupta (BLOOMBERG/ 731 LEX) <[hidden email]>:
I'm using datastreamers to ingest data from files into the cache. I've a need to do an 'upsertion' to the data being ingested, therefore I'm using streamReceiver too.

See attached java class and log snippet. When we run the code calling addData on the datastreamer after a while, we start seeing exceptions being thrown. But this doesn't happen always. I.e. Peerclassloading seems to work at times and not at others with no code change. It seems like there is a race.

Any suggestions on what might be happening or is there a better, more reliable way to do this?


Thanks,
Abhishek