Re: Incorrect Javadoc in CheckpointedFunction.java?

2019-02-14 Thread Congxian Qiu
Hi Chirag I think the doc is outdated, the comments in CheckpointFuncion.java on master now[1] is `get the state data structure for the per-partition state` [1] 

Incorrect Javadoc in CheckpointedFunction.java?

2019-02-14 Thread Chirag Dewan
Hi, I was going through the Javadoc for CheckpointedFunction.java, it says that: * // get the state data structure for the per-key state * countPerKey = context.getKeyedStateStore().getReducingState( * new ReducingStateDescriptor<>("perKeyCount", new