当我们使用reducingstate recordstore.add（r）时，发现性能波动如下所示，
无还原状态：稳定性能图
带还原状态：性能波动图
整体性能（下降超过100%！）：不带reducingstate.add vs带reducingstate.add
它可以很容易地用一个简单的应用程序复制，没有检查点，只是简单地保存记录，还有简单的“求和”归约函数（实际上空函数也会看到相同的结果）。如有任何意见，我们将不胜感激。多么明显的问题啊。
基本上，应用程序只是将记录存储到状态中，我们测量“jsontranslator”中每秒有多少记录，如图所示。两者之间的区别只有一行，comment/un comment“recstore.add（r）”。
了解状态会影响性能，但这就是它的工作方式吗？

DataStream<String> stream = env.addSource(new GeneratorSource(loop);
DataStream<JSONObject> convert = stream.map(new JsonTranslator(statsdUrl))
                                       .keyBy(new KeySelector<JSONObject, AggregationKey>() {... ...})
                                       .process(new ProcessAggregation(aggrDuration, statsdUrl))
                                       .map(new PassthruFunction(statsdUrl));  

public class ProcessAggregation extends ProcessFunction<JSONObject, JSONObject> {
    private ReducingState<JSONObject> recStore;

    public void processElement(JSONObject r, Context ctx, Collector<JSONObject> out) {
        recStore.add(r); //this line make the difference
}