Reduce等函数的对下reuse问题

[赵一旦]

如题，想知道reduce函数实现的时候，什么情况复用对下可能导致问题呢？or永远不可能导致问题呢？


比如计算图中存在很多重复计算：

streamA.reduce(reduceFunction1,....);

streamA.reduce(reduceFunction2,....);

streamA.xxxx