From 92d0784d089b12f28de3c0a21c76649cce11d12c Mon Sep 17 00:00:00 2001 From: Michael Butler Date: Fri, 20 Sep 2024 18:53:35 -0400 Subject: [PATCH] crosscluster/logical: refine lip tags Epic: none Release note: none --- .../logical/logical_replication_writer_processor.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/ccl/crosscluster/logical/logical_replication_writer_processor.go b/pkg/ccl/crosscluster/logical/logical_replication_writer_processor.go index 46a94ada50bc..9c2c3a492409 100644 --- a/pkg/ccl/crosscluster/logical/logical_replication_writer_processor.go +++ b/pkg/ccl/crosscluster/logical/logical_replication_writer_processor.go @@ -261,7 +261,9 @@ func newLogicalReplicationWriterProcessor( // // Start implements the RowSource interface. func (lrw *logicalReplicationWriterProcessor) Start(ctx context.Context) { - ctx = logtags.AddTag(logtags.AddTag(ctx, "job", lrw.spec.JobID), "part", lrw.spec.PartitionSpec.PartitionID) + ctx = logtags.AddTag(ctx, "job", lrw.spec.JobID) + ctx = logtags.AddTag(ctx, "src-node", lrw.spec.PartitionSpec.PartitionID) + ctx = logtags.AddTag(ctx, "proc", lrw.ProcessorID) streampb.RegisterActiveLogicalConsumerStatus(&lrw.debug) ctx = lrw.StartInternal(ctx, logicalReplicationWriterProcessorName)