How are you verifying the data dropping? Can you send 10k, 20k events and
write the same to an output location from spark streaming and verify it? If
you are finding a data mismatch then its a problem with your
MulticastSocket implementation.
Thanks
Best Regards
On Fri, Jan 22, 2016 at 5:44 PM,
Hi,
I have a streaming application with
- 1 sec interval
- accept data from a simulation through MulticastSocket
The simulation sent out data using multiple clients/threads every 1 sec
interval. The input rate accepted by the streaming looks strange.
- When clients = 10,000 the event rate
