fix

alibaba · Dec 27, 2023 · 7db44de · 7db44de
1 parent c3c6227
commit 7db44de
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pluginmanager/plugin_runner_v1.go b/pluginmanager/plugin_runner_v1.go
@@ -447,7 +447,10 @@ func (p *pluginv1Runner) ReceiveLogGroup(logGroup pipeline.LogGroupWithContext)
 			context[ctxKeyTags] = logGroup.LogGroup.LogTags
 			p.ReceiveRawLog(&pipeline.LogWithContext{Log: log, Context: context})
 		} else {
-			context := logGroup.Context
+			context := map[string]interface{}{}
+			for key, value := range logGroup.Context {
+				context[key] = value
+			}
 			context[ctxKeyTopic] = topic
 			for _, tag := range logGroup.LogGroup.LogTags {
 				log.Contents = append(log.Contents, &protocol.Log_Content{