Re: Spark DStream application memory leak debugging

2021-09-25 Thread Sean Owen
It could be 'normal' - executors won't GC unless they need to. It could be state in your application, if you're storing state. You'd want to dump the heap to take a first look On Sat, Sep 25, 2021 at 7:24 AM Kiran Biswal wrote: > Hello Experts > > I have a spark streaming application(DStream). I

Spark DStream application memory leak debugging

2021-09-25 Thread Kiran Biswal
Hello Experts I have a spark streaming application(DStream). I use spark 3.0.2, scala 2.12 This application reads about 20 different kafka topics and produces a single stream and I filter the RDD per topic and store in cassandra I see that there is a steady increase in executor memory over the ho