[streaming] bugfixing in BatchReduceInvokable and CoBatchReduceInvokable