serialization error when using multiple metrics counters
I've created a RichMapFunction in scala with multiple counters like: lazy val successCounter = getRuntimeContext. getMetricGroup.counter("successfulParse") lazy val failedCounter = getRuntimeContext. getMetricGroup.counter("failedParse") lazy val errorCounter = getRuntimeContext. getMetri
Windowed Stream Queryable State Support
What is the state of Windowed Stream Queryable State Support? Is it available in 1.3 or planned for 1.4? Thanks Vijay