@@ -49,7 +49,7 @@ func (i *InfluxDBNode) Init(ctx ruleEngine.Context, config string) error {
}
func (i *InfluxDBNode) OnMessage(ctx ruleEngine.Context, message *protocol.Message) error {
- var tags map[string]string
+ tags := make(map[string]string)
for k, v := range message.MetaData {
tags[k] = v.(string)