diff --git a/internal/component/otelcol/connector/connector.go b/internal/component/otelcol/connector/connector.go index dad87402e..4a5f2b223 100644 --- a/internal/component/otelcol/connector/connector.go +++ b/internal/component/otelcol/connector/connector.go @@ -214,7 +214,7 @@ func (p *Connector) Update(args component.Arguments) error { return errors.New("unsupported connector type") } - // Pause the consumer, because we need to scheduler to run the new components before they receive any traffic. + // Pause the consumer, because we need the scheduler to run the new components before they receive any traffic. p.consumer.Pause() p.consumer.SetConsumers(tracesConnector, metricsConnector, logsConnector) // Schedule the components. The scheduler will resume the consumer once the components are running. diff --git a/internal/component/otelcol/exporter/exporter.go b/internal/component/otelcol/exporter/exporter.go index f9cc62861..95d2ced67 100644 --- a/internal/component/otelcol/exporter/exporter.go +++ b/internal/component/otelcol/exporter/exporter.go @@ -242,7 +242,7 @@ func (e *Exporter) Update(args component.Arguments) error { } } - // Pause the consumer, because we need to scheduler to run the new components before they receive any traffic. + // Pause the consumer, because we need the scheduler to run the new components before they receive any traffic. e.consumer.Pause() e.consumer.SetConsumers(tracesExporter, metricsExporter, logsExporter) // Schedule the components. The scheduler will resume the consumer once the components are running. diff --git a/internal/component/otelcol/processor/processor.go b/internal/component/otelcol/processor/processor.go index 948e383ab..e466bdbc1 100644 --- a/internal/component/otelcol/processor/processor.go +++ b/internal/component/otelcol/processor/processor.go @@ -237,7 +237,7 @@ func (p *Processor) Update(args component.Arguments) error { } } - // Pause the consumer, because we need to scheduler to run the new components before they receive any traffic. + // Pause the consumer, because we need the scheduler to run the new components before they receive any traffic. p.consumer.Pause() p.consumer.SetConsumers(tracesProcessor, metricsProcessor, logsProcessor) // Schedule the components. The scheduler will resume the consumer once the components are running.