fix: address race condition in points_writer

influxdata · Aug 3, 2020 · 6679fac · 6679fac
1 parent 7a5d6f4
commit 6679fac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/coordinator/points_writer.go b/coordinator/points_writer.go
@@ -335,7 +335,7 @@ func (w *PointsWriter) WritePointsPrivilegedWithContext(ctx context.Context, dat
 	for shardID, points := range shardMappings.Points {
 		go func(shard *meta.ShardInfo, database, retentionPolicy string, points []models.Point) {
 			var numPoints, numValues int64
-			ctx = context.WithValue(ctx, tsdb.StatPointsWritten, &numPoints)
+			ctx := context.WithValue(ctx, tsdb.StatPointsWritten, &numPoints)
 			ctx = context.WithValue(ctx, tsdb.StatValuesWritten, &numValues)
 
 			err := w.writeToShardWithContext(ctx, shard, database, retentionPolicy, points)