Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

panic: reflect: call of reflect.Value.Type on zero Value #153

Closed
wtfuzz opened this issue Jan 19, 2016 · 2 comments
Closed

panic: reflect: call of reflect.Value.Type on zero Value #153

wtfuzz opened this issue Jan 19, 2016 · 2 comments

Comments

@wtfuzz
Copy link

wtfuzz commented Jan 19, 2016

I've had the following panic:

2016/01/19 16:32:46 Using configuration at: /etc/kapacitor/kapacitor.conf
panic: reflect: call of reflect.Value.Type on zero Value

goroutine 134 [running]:
reflect.Value.Type(0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/local/go/src/reflect/value.go:1664 +0x7b
github.com/influxdb/influxdb/tsdb.typeCompare(0x0, 0x0, 0x0, 0x0, 0xc82040f080, 0x0, 0x0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/influxdb/tsdb/functions.go:1135 +0xd8
github.com/influxdb/influxdb/tsdb.(*topBottomMapOut).positionPointLess(0xc82020d698, 0xc82041ea90, 0xc82041e9c0, 0x0)
    /gopath/src/github.com/influxdb/influxdb/tsdb/functions.go:1348 +0x6b
github.com/influxdb/influxdb/tsdb.ReduceTopBottom(0xc820420540, 0x2, 0x2, 0x5, 0xf99198, 0x0, 0x0, 0xbc60e0, 0x3, 0x0, ...)
    /gopath/src/github.com/influxdb/influxdb/tsdb/functions.go:1610 +0x7f6
github.com/influxdb/kapacitor.influxqlMapReducers.Top.func2(0xc820420540, 0x2, 0x2, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/functions.go:86 +0x88
github.com/influxdb/kapacitor.reduce.func1(0xc820420540, 0x2, 0x2, 0xece30b08f, 0x30e9e8ae, 0xf6a7a0, 0xcb6a600, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/functions.go:119 +0x7e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc8202036c0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:179 +0x14e
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202036c0)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 1 [chan receive]:
main.(*Main).Run(0xc820127ef0, 0xc82000a190, 0x2, 0x2, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/cmd/kapacitord/main.go:96 +0xbf1
main.main()
    /gopath/src/github.com/influxdb/kapacitor/cmd/kapacitord/main.go:41 +0x363

goroutine 17 [syscall, locked to thread]:
runtime.goexit()
    /usr/local/go/src/runtime/asm_amd64.s:1696 +0x1

goroutine 5 [syscall]:
os/signal.loop()
    /usr/local/go/src/os/signal/signal_unix.go:22 +0x18
created by os/signal.init.1
    /usr/local/go/src/os/signal/signal_unix.go:28 +0x37

goroutine 70 [IO wait]:
net.runtime_pollWait(0x7f184d46b570, 0x72, 0xc82000e1b0)
    /usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8201cc5a0, 0x72, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8201cc5a0, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).readFrom(0xc8201cc540, 0xc8202b4000, 0x10000, 0x10000, 0x0, 0x0, 0x0, 0x7f184d465050, 0xc82000e1b0)
    /usr/local/go/src/net/fd_unix.go:259 +0x2a5
net.(*UDPConn).ReadFromUDP(0xc820280040, 0xc8202b4000, 0x10000, 0x10000, 0x10000, 0x10000, 0x0, 0x0)
    /usr/local/go/src/net/udpsock_posix.go:61 +0x117
github.com/influxdb/kapacitor/services/udp.(*Service).serve(0xc820270280)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:125 +0x166
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:103 +0xc39

goroutine 8 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc82014aba0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*TaskMaster).runForking(0xc820158000, 0xc82014aba0)
    /gopath/src/github.com/influxdb/kapacitor/task_master.go:265 +0xcc
created by github.com/influxdb/kapacitor.(*TaskMaster).stream
    /gopath/src/github.com/influxdb/kapacitor/task_master.go:259 +0x14f

goroutine 30 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8203311a0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*MapNode).runStreamMap(0xc820208460, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:66 +0x11b
github.com/influxdb/kapacitor.(*MapNode).runMaps(0xc820208460, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:56 +0x55
github.com/influxdb/kapacitor.(*MapNode).(github.com/influxdb/kapacitor.runMaps)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:49 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820208460)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 27 [select]:
github.com/influxdb/kapacitor.(*Edge).NextBatch(0xc820330b40, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:134 +0x371
github.com/influxdb/kapacitor.(*MapNode).runBatchMap(0xc8202082a0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:98 +0x86
github.com/influxdb/kapacitor.(*MapNode).runMaps(0xc8202082a0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:58 +0x83
github.com/influxdb/kapacitor.(*MapNode).(github.com/influxdb/kapacitor.runMaps)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:49 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202082a0)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 18 [IO wait]:
net.runtime_pollWait(0x7f184d46b7b0, 0x72, 0xc82000e1b0)
    /usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc820118ae0, 0x72, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc820118ae0, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).accept(0xc820118a80, 0x0, 0x7f184a635028, 0xc820178000)
    /usr/local/go/src/net/fd_unix.go:408 +0x27c
net.(*TCPListener).AcceptTCP(0xc82002e130, 0x4554d0, 0x0, 0x0)
    /usr/local/go/src/net/tcpsock_posix.go:254 +0x4d
net.(*TCPListener).Accept(0xc82002e130, 0x0, 0x0, 0x0, 0x0)
    /usr/local/go/src/net/tcpsock_posix.go:264 +0x3d
net/http.(*Server).Serve(0xc820172000, 0x7f184d46a830, 0xc82002e130, 0x0, 0x0)
    /usr/local/go/src/net/http/server.go:1887 +0xb3
net/http.Serve(0x7f184d46a830, 0xc82002e130, 0x7f184a635000, 0xc820018a20, 0x0, 0x0)
    /usr/local/go/src/net/http/server.go:1765 +0x85
github.com/influxdb/kapacitor/services/httpd.(*Service).serve.func1(0xc820013860)
    /gopath/src/github.com/influxdb/kapacitor/services/httpd/service.go:114 +0x6e
created by github.com/influxdb/kapacitor/services/httpd.(*Service).serve
    /gopath/src/github.com/influxdb/kapacitor/services/httpd/service.go:122 +0x35

goroutine 68 [IO wait]:
net.runtime_pollWait(0x7f184d46b630, 0x72, 0xc82000e1b0)
    /usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8201cc450, 0x72, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8201cc450, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).readFrom(0xc8201cc3f0, 0xc82029e000, 0x10000, 0x10000, 0x0, 0x0, 0x0, 0x7f184d465050, 0xc82000e1b0)
    /usr/local/go/src/net/fd_unix.go:259 +0x2a5
net.(*UDPConn).ReadFromUDP(0xc820280028, 0xc82029e000, 0x10000, 0x10000, 0x10000, 0x10000, 0x0, 0x0)
    /usr/local/go/src/net/udpsock_posix.go:61 +0x117
github.com/influxdb/kapacitor/services/udp.(*Service).serve(0xc8202701e0)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:125 +0x166
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:103 +0xc39

goroutine 69 [chan receive]:
github.com/influxdb/kapacitor/services/udp.(*Service).processPackets(0xc8202701e0)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:143 +0xe6
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:105 +0xc84

goroutine 67 [chan receive]:
github.com/influxdb/kapacitor/services/udp.(*Service).processPackets(0xc820270140)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:143 +0xe6
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:105 +0xc84

goroutine 66 [IO wait]:
net.runtime_pollWait(0x7f184d46b6f0, 0x72, 0xc82000e1b0)
    /usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8201cc300, 0x72, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8201cc300, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).readFrom(0xc8201cc2a0, 0xc820288000, 0x10000, 0x10000, 0x0, 0x0, 0x0, 0x7f184d465050, 0xc82000e1b0)
    /usr/local/go/src/net/fd_unix.go:259 +0x2a5
net.(*UDPConn).ReadFromUDP(0xc820280010, 0xc820288000, 0x10000, 0x10000, 0x10000, 0x10000, 0x0, 0x0)
    /usr/local/go/src/net/udpsock_posix.go:61 +0x117
github.com/influxdb/kapacitor/services/udp.(*Service).serve(0xc820270140)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:125 +0x166
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:103 +0xc39

goroutine 29 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc820330f60, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*GroupByNode).runGroupBy(0xc820208380, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/group_by.go:33 +0xcb
github.com/influxdb/kapacitor.(*GroupByNode).(github.com/influxdb/kapacitor.runGroupBy)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/group_by.go:24 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820208380)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 28 [select]:
github.com/influxdb/kapacitor.(*Edge).NextMaps(0xc820330d50, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:153 +0x34e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc8202028f0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:178 +0x98
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202028f0)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 26 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc820330900, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*WindowNode).runWindow(0xc820326300, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/window.go:31 +0x11b
github.com/influxdb/kapacitor.(*WindowNode).(github.com/influxdb/kapacitor.runWindow)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/window.go:24 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820326300)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 71 [chan receive]:
github.com/influxdb/kapacitor/services/udp.(*Service).processPackets(0xc820270280)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:143 +0xe6
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:105 +0xc84

goroutine 72 [IO wait]:
net.runtime_pollWait(0x7f184d46b4b0, 0x72, 0xc82000e1b0)
    /usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8201cc6f0, 0x72, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8201cc6f0, 0x0, 0x0)
    /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).readFrom(0xc8201cc690, 0xc8202ca000, 0x10000, 0x10000, 0x0, 0x0, 0x0, 0x7f184d465050, 0xc82000e1b0)
    /usr/local/go/src/net/fd_unix.go:259 +0x2a5
net.(*UDPConn).ReadFromUDP(0xc820280058, 0xc8202ca000, 0x10000, 0x10000, 0x10000, 0x10000, 0x0, 0x0)
    /usr/local/go/src/net/udpsock_posix.go:61 +0x117
github.com/influxdb/kapacitor/services/udp.(*Service).serve(0xc820270320)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:125 +0x166
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:103 +0xc39

goroutine 73 [chan receive]:
github.com/influxdb/kapacitor/services/udp.(*Service).processPackets(0xc820270320)
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:143 +0xe6
created by github.com/influxdb/kapacitor/services/udp.(*Service).Open
    /gopath/src/github.com/influxdb/kapacitor/services/udp/service.go:105 +0xc84

goroutine 25 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8203306c0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*StreamNode).runStream(0xc82032a360, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:41 +0x89
github.com/influxdb/kapacitor.(*StreamNode).(github.com/influxdb/kapacitor.runStream)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:29 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc82032a360)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 76 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc820302810, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*StreamNode).runStream(0xc82027f440, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:41 +0x89
github.com/influxdb/kapacitor.(*StreamNode).(github.com/influxdb/kapacitor.runStream)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:29 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc82027f440)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 77 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8202e9470, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*StreamNode).runStream(0xc82027f560, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:41 +0x89
github.com/influxdb/kapacitor.(*StreamNode).(github.com/influxdb/kapacitor.runStream)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:29 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc82027f560)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 78 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8202e9680, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*WindowNode).runWindow(0xc8202f6840, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/window.go:31 +0x11b
github.com/influxdb/kapacitor.(*WindowNode).(github.com/influxdb/kapacitor.runWindow)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/window.go:24 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202f6840)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 79 [select]:
github.com/influxdb/kapacitor.(*Edge).NextBatch(0xc8202e9890, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:134 +0x371
github.com/influxdb/kapacitor.(*MapNode).runBatchMap(0xc8202dc460, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:98 +0x86
github.com/influxdb/kapacitor.(*MapNode).runMaps(0xc8202dc460, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:58 +0x83
github.com/influxdb/kapacitor.(*MapNode).(github.com/influxdb/kapacitor.runMaps)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:49 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202dc460)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 80 [select]:
github.com/influxdb/kapacitor.(*Edge).NextMaps(0xc8202e9aa0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:153 +0x34e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc8201caa90, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:178 +0x98
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8201caa90)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 81 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8202e9cb0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*DerivativeNode).runDerivative(0xc8202f6900, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/derivative.go:30 +0x15e
github.com/influxdb/kapacitor.(*DerivativeNode).(github.com/influxdb/kapacitor.runDerivative)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/derivative.go:22 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202f6900)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 82 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8202e9ef0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*MapNode).runStreamMap(0xc8202dc540, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:66 +0x11b
github.com/influxdb/kapacitor.(*MapNode).runMaps(0xc8202dc540, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:56 +0x55
github.com/influxdb/kapacitor.(*MapNode).(github.com/influxdb/kapacitor.runMaps)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:49 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202dc540)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 83 [select]:
github.com/influxdb/kapacitor.(*Edge).NextMaps(0xc820302120, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:153 +0x34e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc8201cab60, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:178 +0x98
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8201cab60)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 84 [select]:
github.com/influxdb/kapacitor.(*Edge).NextBatch(0xc820302360, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:134 +0x371
github.com/influxdb/kapacitor.(*HTTPOutNode).runOut(0xc820304000, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/http_out.go:91 +0x6a3
github.com/influxdb/kapacitor.(*HTTPOutNode).(github.com/influxdb/kapacitor.runOut)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/http_out.go:34 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820304000)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 85 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc8203025d0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*HTTPOutNode).runOut(0xc820304140, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/http_out.go:86 +0x52e
github.com/influxdb/kapacitor.(*HTTPOutNode).(github.com/influxdb/kapacitor.runOut)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/http_out.go:34 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820304140)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 86 [chan receive]:
github.com/influxdb/kapacitor.(*node).Err(0xc820304140, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/node.go:111 +0xc6
github.com/influxdb/kapacitor.(*ExecutingTask).Err.func1(0x7f18495b3d40, 0xc820304140, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/task.go:269 +0x33
github.com/influxdb/kapacitor.(*ExecutingTask).rwalk(0xc82025ed70, 0xd0c570, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/task.go:142 +0x91
github.com/influxdb/kapacitor.(*ExecutingTask).Err(0xc82025ed70, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/task.go:270 +0x39
github.com/influxdb/kapacitor/services/task_store.(*Service).StartTask.func1(0xc82025ed70, 0xc820018a80, 0xc8201c7440)
    /gopath/src/github.com/influxdb/kapacitor/services/task_store/service.go:517 +0x30
created by github.com/influxdb/kapacitor/services/task_store.(*Service).StartTask
    /gopath/src/github.com/influxdb/kapacitor/services/task_store/service.go:529 +0x224

goroutine 24 [select]:
github.com/influxdb/kapacitor.(*Edge).NextPoint(0xc820349b90, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:115 +0x364
github.com/influxdb/kapacitor.(*StreamNode).runStream(0xc82032a240, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:41 +0x89
github.com/influxdb/kapacitor.(*StreamNode).(github.com/influxdb/kapacitor.runStream)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/stream.go:29 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc82032a240)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 31 [select]:
github.com/influxdb/kapacitor.(*Edge).NextMaps(0xc8203313e0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:153 +0x34e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc8202029c0, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:178 +0x98
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc8202029c0)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 32 [select]:
github.com/influxdb/kapacitor.(*Edge).NextBatch(0xc820331620, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:134 +0x371
github.com/influxdb/kapacitor.(*SampleNode).runSample(0xc820202a90, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/sample.go:48 +0x34f
github.com/influxdb/kapacitor.(*SampleNode).(github.com/influxdb/kapacitor.runSample)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/sample.go:27 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820202a90)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 33 [select]:
github.com/influxdb/kapacitor.(*Edge).NextBatch(0xc820331860, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:134 +0x371
github.com/influxdb/kapacitor.(*MapNode).runBatchMap(0xc820208540, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:98 +0x86
github.com/influxdb/kapacitor.(*MapNode).runMaps(0xc820208540, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:58 +0x83
github.com/influxdb/kapacitor.(*MapNode).(github.com/influxdb/kapacitor.runMaps)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:49 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820208540)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

goroutine 98 [select]:
github.com/influxdb/kapacitor.(*Edge).NextMaps(0xc820331a70, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/edge.go:153 +0x34e
github.com/influxdb/kapacitor.(*ReduceNode).runReduce(0xc820202b60, 0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:178 +0x98
github.com/influxdb/kapacitor.(*ReduceNode).(github.com/influxdb/kapacitor.runReduce)-fm(0x0, 0x0)
    /gopath/src/github.com/influxdb/kapacitor/map_reduce.go:173 +0x2e
github.com/influxdb/kapacitor.(*node).start.func1(0xc820202b60)
    /gopath/src/github.com/influxdb/kapacitor/node.go:95 +0x5e
created by github.com/influxdb/kapacitor.(*node).start
    /gopath/src/github.com/influxdb/kapacitor/node.go:96 +0x6b

With the following TICKscript:

var actionCount = stream
    .from().measurement('user')
    .groupBy('srcip')
    .window()
        .period(11s)
        .every(1s)
    //.mapReduce(influxql.count('action'))

actionCount.httpOut('action_count')

actionCount
  .mapReduce(influxql.top(5, 'count')).httpOut('top_users')
@wtfuzz
Copy link
Author

wtfuzz commented Jan 19, 2016

Points were being generated with the following:

host=${1-localhost}
port=${2-9500}

actions=("login" "logout")
users=("alice" "bob")

while true
do
  # Generate a random IP address from a pool of 16
  srcip=10.0.0.$((RANDOM%16))
  user=${users[$RANDOM % ${#users[@]} ]}
  action=${actions[$RANDOM % ${#actions[@]} ]}
  echo "user,srcip=$srcip,user=$user action=\"$action\"" > /dev/udp/$host/$port
  sleep 0.1
done

@nathanielc
Copy link
Contributor

@wtfuzz There is an error in the TICKscript on this line:

actionCount
  .mapReduce(influxql.top(5, 'count')).httpOut('top_users')

should be

actionCount
  .mapReduce(influxql.top(5, 'action')).httpOut('top_users')

That it panics is obviously bad and I have a fix coming.

@nathanielc nathanielc mentioned this issue Jan 20, 2016
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@wtfuzz @nathanielc