Skip to content

Commit 4ab4a9c

Browse files
committed
Revert "Clear trace response instead of metric response in OTelExportSinkNode::ConsumeSpans (#1910)"
This reverts commit 970a54a.
1 parent 11234fb commit 4ab4a9c

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/carnot/exec/otel_export_sink_node.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -340,7 +340,7 @@ Status OTelExportSinkNode::ConsumeSpans(ExecState* exec_state, const RowBatch& r
340340
}
341341
context.set_compression_algorithm(GRPC_COMPRESS_GZIP);
342342

343-
trace_response_.Clear();
343+
metrics_response_.Clear();
344344
opentelemetry::proto::collector::trace::v1::ExportTraceServiceRequest request;
345345

346346
for (int64_t row_idx = 0; row_idx < rb.ColumnAt(0)->length(); ++row_idx) {

src/carnot/planner/objects/otel.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -338,6 +338,7 @@ Status OTelModule::Init(CompilerState* compiler_state, IR* ir) {
338338

339339
AddMethod(kEndpointOpID, endpoint_fn);
340340
PX_RETURN_IF_ERROR(endpoint_fn->SetDocString(kEndpointOpDocstring));
341+
return Status::OK();
341342

342343
return Status::OK();
343344
}

0 commit comments

Comments
 (0)