fix(stream): let Row Merge executor handle extra row count column i…

fix(stream): let Row Merge executor handle extra row count column i… #6267