address comments

open-telemetry · Jun 4, 2021 · 7e69a99 · 7e69a99
1 parent 401b884
commit 7e69a99
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/obsreport/obsreport_pipeline.go b/obsreport/obsreport_pipeline.go
@@ -19,10 +19,10 @@ import (
 	"time"
 
 	"go.opencensus.io/stats"
+
 	"go.opentelemetry.io/collector/internal/obsreportconfig/obsmetrics"
 )
 
-
 type pipelineStartContextKey struct{}
 
 func recordPipelineStart(ctx context.Context) context.Context {

diff --git a/processor/batchprocessor/batch_processor.go b/processor/batchprocessor/batch_processor.go
@@ -181,7 +181,9 @@ func (bp *batchProcessor) sendItems(triggerMeasure *stats.Int64Measure) {
 	if err := bp.batch.export(bp.exportCtx, bp.sendBatchMaxSize); err != nil {
 		bp.logger.Warn("Sender failed", zap.Error(err))
 	}
-	// Reset the context
+	// The accumulated b.exportCtx was associated with the batch of telemetry
+	// we just exported.  Clear the context so that the next bacth is sent only
+	// with contexts used when constructing it.
 	bp.exportCtx = context.Background()
 }