I have implemented a simple Spark streaming application to perform windowing wordcount job. However, it seems that the latency is extremely high, compared with running exactly the same job in Storm. The source code is attached as follows:
Do you see a stable latency or the latency keeps increasing? And could you provide some details about the input data rate/node, batch interval, windowDuration and slideDuration when you see the high latency?