Don't use ephemeral code for journal event participants

Signed-off-by: Matt Lord <[email protected]>
vitessio · Jan 31, 2025 · d98f471 · d98f471
1 parent d878c2d
commit d98f471
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)
 			}
 		}