serialization error when using multiple metrics counters

2017-10-07 Thread Colin Williams
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

2017-10-07 Thread vijayakumar palaniappan
What is the state of Windowed Stream Queryable State Support? Is it available in 1.3 or planned for 1.4? Thanks Vijay