flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Janardhan Reddy <janardhan.re...@olacabs.com>
Subject checkpoint state keeps on increasing
Date Thu, 18 Aug 2016 06:11:22 GMT
Hi,

I am noticing that the checkpointing state has been constantly growing for
the below subtask. Only the current active window elements should be
checkpointed ? why is it constantly growing ?

finalStream.keyBy("<>").countWindow(2,1)
  .apply((_, _, input: scala.Iterable[], out: Collector[]) => {
    val inputArray = input.toArray

... do something

}

Mime
View raw message