在flink聚合函数中修改输入对象是否安全？样本代码：

class Acc {
    int sum = 0;
    int max = 0;
}
public class MyAggFunc implements AggregateFunction<Integer, Acc, Acc> {
    @Override
    public Acc createAccumulator() {
        return new Acc();
    }

    @Override
    public Acc add(Integer value, Acc accumulator) {
        accumulator.sum += value;
        accumulator.max = Math.max(accumulator.max, value);
        return accumulator
    }

    @Override
    public Acc getResult(Acc accumulator) {
        return accumulator
    }

    @Override
    public Acc merge(Acc a, Acc b) {
        a.max = Math.max(a.max, b.max);
        a.sum += b.sum;
        return a;
    }
}

在add（）和merge（）中，我修改了输入累加器并返回它，以避免在每次调用中创建新对象。安全吗？