Flink Gelly. Почему агрегатор будет сброшен в следующей итерации?
Это мой код
Это кажется правильным до сих пор, но в следующем супершаге я все равно получаю 5, а не 10! Кажется, агрегатор был сброшен. Что я могу сделать для хранения каждого значения superStep?
Кстати, я хочу получить значение агрегатора за пределами GatherFunction, есть ли метод?