fix bug in event processing in transform_data

aliyun · Dec 24, 2018 · 13110be · 13110be
1 parent 2220a39
commit 13110be
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aliyun/log/logclient_operator.py b/aliyun/log/logclient_operator.py
@@ -669,7 +669,7 @@ def _transform_events_to_logstore(runner, events, to_client, to_project, to_logs
                 source = event['__source__']
                 del event["__source__"]
 
-            new_events[(dt, topic, source)].append(new_event)
+            new_events[(dt, topic, source)].append(event)
 
     for (dt, topic, source), contents in six.iteritems(new_events):