Skip to content

Commit 6f2fbb3

Browse files
committed
review comment
1 parent 1f06b50 commit 6f2fbb3

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

opentelemetry-sdk/src/trace/config.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -161,21 +161,21 @@ impl Default for Config {
161161
"parentbased_jaeger_remote" => {
162162
otel_warn!(
163163
name: "Sampler.ParentBasedJaegerRemote.Unsupported",
164-
message = "ParentBased JaegerRemote sampler is not implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
164+
message = "OTEL_TRACES_SAMPLER is set to 'parentbased_jaeger_remote' which is not implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
165165
);
166166
Box::new(Sampler::ParentBased(Box::new(Sampler::AlwaysOn)))
167167
}
168168
"jaeger_remote" => {
169169
otel_warn!(
170170
name: "Sampler.JaegerRemote.Unsupported",
171-
message = "JaegerRemote sampler is not implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
171+
message = "OTEL_TRACES_SAMPLER is set to 'jaeger_remote' which is implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
172172
);
173173
Box::new(Sampler::ParentBased(Box::new(Sampler::AlwaysOn)))
174174
}
175175
"xray" => {
176176
otel_warn!(
177177
name: "Sampler.XRay.Unsupported",
178-
message = "AWS X-Ray sampler is not implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
178+
message = "OTEL_TRACES_SAMPLER is set to 'xray'. AWS X-Ray sampler is not implemented in this SDK version. Using fallback sampler: ParentBased(AlwaysOn). Configure an alternative sampler using OTEL_TRACES_SAMPLER"
179179
);
180180
Box::new(Sampler::ParentBased(Box::new(Sampler::AlwaysOn)))
181181
}

opentelemetry-sdk/src/trace/span_processor.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,8 @@ impl SpanProcessor for SimpleSpanProcessor {
134134
.and_then(|mut exporter| futures_executor::block_on(exporter.export(vec![span])));
135135

136136
if let Err(err) = result {
137-
otel_error!(
137+
// TODO: check error type, and log `error` only if the error is user-actiobable, else log `debug`
138+
otel_debug!(
138139
name: "SimpleProcessor.OnEnd.Error",
139140
reason = format!("{:?}", err)
140141
);
@@ -249,8 +250,8 @@ impl<R: RuntimeChannel> SpanProcessor for BatchSpanProcessor<R> {
249250
let result = self.message_sender.try_send(BatchMessage::ExportSpan(span));
250251

251252
if let Err(err) = result {
252-
otel_error!(
253-
name: "BatchProcessor.OnEnd.Error",
253+
otel_debug!(
254+
name: "BatchSpanProcessor.OnEnd.SendResultError",
254255
reason = format!("{:?}", TraceError::Other(err.into()))
255256
);
256257
}
@@ -368,7 +369,7 @@ impl<R: RuntimeChannel> BatchSpanProcessorInternal<R> {
368369
let task = async move {
369370
if let Err(err) = export_task.await {
370371
otel_error!(
371-
name: "BatchSpanProcessor.Export.Error",
372+
name: "BatchSpanProcessor.OnEnd.Error",
372373
reason = format!("{}", err)
373374
);
374375
}

0 commit comments

Comments
 (0)