fix

Signed-off-by: Song Gao <[email protected]>
lf-edge · Oct 11, 2024 · 7fa4b1f · 7fa4b1f
1 parent 0014bf2
commit 7fa4b1f
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/docs/en_US/api/restapi/trace.md b/docs/en_US/api/restapi/trace.md
@@ -4,8 +4,14 @@ eKuiper supports viewing recent tracing data of rules through API.
 
 ## Start trace the data of specific rule
 
+Turn on the data tracing of the rules. The strategy supports `always` and `head`. `always` means that each message is always traced, and `head` means that only upstream messages containing trace context will be traced.
+
 ```shell
 POST http://localhost:9081/rule/{ruleID}/trace/start
+
+{
+    "strategy": "head"
+}
 ```
 
 ## Stop trace the data of specific rule

diff --git a/docs/zh_CN/api/restapi/trace.md b/docs/zh_CN/api/restapi/trace.md
@@ -4,8 +4,14 @@ eKuiper 支持通过 API 查看规则最近的追踪数据。
 
 ## 开启特定规则的数据追踪
 
+开启规则的数据追踪，strategy 支持 `always` 与 `head`. `always` 代表总是对每条消息进行追踪，`head` 代表只有上游消息含有 trace context 才会进行追踪。
+
 ```shell
 POST http://localhost:9081/rule/{ruleID}/trace/start
+
+{
+    "strategy": "head"
+}
 ```
 
 ## 关闭特定规则的数据追踪

diff --git a/internal/io/neuron/sink.go b/internal/io/neuron/sink.go
@@ -220,7 +220,6 @@ func extractSpanContextIntoData(ctx api.StreamContext, data interface{}, sendByt
 		defer span.End()
 		traceID := span.SpanContext().TraceID()
 		spanID := span.SpanContext().SpanID()
-		defer span.End()
 		r := NeuronTraceHeader
 		r = append(r, traceID[:]...)
 		r = append(r, spanID[:]...)