[streaming] batchReduce reduceLastBatch bugfix