[streaming] GroupReduceInvokable update