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
Description: Binary data
CassStreamReceiverPeerLoading.java
Description: Binary data
