diff --git a/go/vt/vtgate/vstream_manager.go b/go/vt/vtgate/vstream_manager.go
index 3a8e98f1c66..43f38d2755d 100644
--- a/go/vt/vtgate/vstream_manager.go
+++ b/go/vt/vtgate/vstream_manager.go
@@ -956,7 +956,7 @@ func (vs *vstream) getJournalEvent(ctx context.Context, sgtid *binlogdatapb.Shar
 						mode = matchAll
 						je.participants[inner] = false
 					case matchNone:
-						return nil, vterrors.Errorf(vtrpcpb.Code_FAILED_PRECONDITION, "not all journaling participants are in the stream: journal: %v, stream: %v",
+						return nil, vterrors.Errorf(vtrpcpb.Code_ABORTED, "not all journaling participants are in the stream: journal: %v, stream: %v",
 							journal.Participants, vs.vgtid.ShardGtids)
 					}
 					continue nextParticipant
@@ -966,7 +966,7 @@ func (vs *vstream) getJournalEvent(ctx context.Context, sgtid *binlogdatapb.Shar
 			case undecided, matchNone:
 				mode = matchNone
 			case matchAll:
-				return nil, vterrors.Errorf(vtrpcpb.Code_FAILED_PRECONDITION, "not all journaling participants are in the stream: journal: %v, stream: %v",
+				return nil, vterrors.Errorf(vtrpcpb.Code_ABORTED, "not all journaling participants are in the stream: journal: %v, stream: %v",
 					journal.Participants, vs.vgtid.ShardGtids)
 			}
 		}