influxdata / influxdata/kapacitor
Panic on closed channel over udf
- Dominant language
- Go
- Stars
- 2.4k
- Forks
- 479
- Avg merge
- 4d 16h
- Merged PRs (30d)
- 4
Description
Hi while working with an UDF my kapacitor (Kapacitor 1.3.3 (git: master eacb3730de19d7c70b6481f53100c20850d30b8b) has crashed.
These are my UDF last logs
````
time="2017-09-28 12:10:25" level=info msg="Agent for connection 15 finished"
time="2017-09-28 12:10:25" level=info msg="Starting agent for connection 19"
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"alertId\" values: "
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"searchByTag\" values: "
time="2017-09-28 12:10:25" level=info msg="Agent for connection 16 finished"
time="2017-09-28 12:10:25" level=info msg="Starting agent for connection 20"
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"alertId\" values: "
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"searchByTag\" values: "
time="2017-09-28 12:10:25" level=info msg="Starting agent for connection 21"
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"alertId\" values: "
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"searchByTag\" values: "
time="2017-09-28 12:10:25" level=info msg="Starting agent for connection 22"
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"alertId\" values: "
time="2017-09-28 12:10:25" level=info msg="Iniciando opciones: name:\"searchByTag\" values: "
time="2017-09-28 12:11:19" level=info msg=" > host,alertid,mon_active,mon_linia,mon_exc,monFilterTagKey,monFilterTagValue"
time="2017-09-28 12:12:10" level=info msg="Agent for connection 19 finished"
time="2017-09-28 12:12:10" level=info msg="Agent for connection 20 finished"
time="2017-09-28 12:12:10" level=fatal msg="read error: read unix /tmp/monInjector.sock->@: read: connection reset by peer"
````
And these the panic on kapacitor
````
panic: send on closed channel
goroutine 5154595 [running]:
github.com/influxdata/kapacitor/edge.(*channelEdge).Collect(0xc4741ceed0, 0x7f8690e972e0, 0xc475019e60, 0xc, 0x17)
/home/developer/src/gospace/src/github.com/influxdata/kapacitor/edge/edge.go:58 +0x12d
github.com/influxdata/kapacitor/edge.(*streamStatsEdge).Collect(0xc437de0180, 0x7f8690e972e0, 0xc475019e60, 0xc4202779c0, 0xc46ed1cb38)
/home/developer/src/gospace/src/github.com/influxdata/kapacitor/edge/stats.go:207 +0x4b
github.com/influxdata/kapacitor.(*Edge).Collect(0xc46529b860, 0x7f8690e972e0, 0xc475019e60, 0xc46ed1cae0, 0xc45cd11f90)
:611 +0x5d
github.com/influxdata/kapacitor/edge.Forward(0xc4587ddf40, 0x1, 0x1, 0x7f8690e972e0, 0xc475019e60, 0x0, 0x0)
/home/developer/src/gospace/src/github.com/influxdata/kapacitor/edge/forwarding.go:98 +0x61
github.com/influxdata/kapacitor.(*UDFNode).runUDF.func2(0xc42eb14dc0, 0xc46ed1cde0)
/home/developer/src/gospace/src/github.com/influxdata/kapacitor/udf.go:96 +0xdf
created by github.com/influxdata/kapacitor.(*UDFNode).runUDF
/home/developer/src/gospace/src/github.com/influxdata/kapacitor/udf.go:102 +0x15f
````
Contributor guide
Assessment
This issue has not been assessed yet.