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 with join + eval #331

Closed
nathanielc opened this issue Mar 15, 2016 · 4 comments
Closed

Panic with join + eval #331

nathanielc opened this issue Mar 15, 2016 · 4 comments

Comments

@nathanielc
Copy link
Contributor

Exceprt of TICKscript

join(ssCpuRawSystem,ssCpuRawNice,ssCpuRawWait,ssCpuRawInt,ssCpuRawKernel,ssCpuRawSoftIRQ,ssCpuRawIdle) 
            .eval(lambda: "ssCpuRawUser.ssCpuRawUserDeriv" + "ssCpuRawSystem.ssCpuRawSystemDeriv") 
                         .as('divisor') 
                         .keep() 
                       .eval(lambda: "ssCpuRawUser.ssCpuRawUserDeriv" / "divisor" * float(100), lambda: "ssCpuRawSystem.ssCpuRawSystemDeriv" / "divisor" * float(100)) 
                         .as('user', 'system')

all other tasks were disabled to ensure a cleaner stacktrace:

2016/03/15 09:48:33 Using configuration at: /etc/kapacitor/kapacitor.conf 
panic: runtime error: index out of range 

goroutine 120 [running]: 
github.com/influxdata/kapacitor.(*group).collect(0xc8200144b0, 0x0, 0x7fe0f0b3dc40, 0xc8201e4500) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:190 +0x778 
github.com/influxdata/kapacitor.(*group).run(0xc8200144b0) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:173 +0xf8 
created by github.com/influxdata/kapacitor.(*JoinNode).getGroup 
        /root/go/src/github.com/influxdata/kapacitor/join.go:110 +0x333 

goroutine 1 [chan receive, 1 minutes]: 
main.(*Main).Run(0xc8203b3f10, 0xc82000a1c0, 0x2, 0x2, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/main.go:96 +0xbf1 
main.main() 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/main.go:41 +0x363 

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

goroutine 5 [syscall, 1 minutes]: 
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 34 [IO wait]: 
net.runtime_pollWait(0x7fe0eeaf2090, 0x72, 0xc820010190) 
        /usr/local/go/src/runtime/netpoll.go:157 +0x60 
net.(*pollDesc).Wait(0xc82013f950, 0x72, 0x0, 0x0) 
        /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a 
net.(*pollDesc).WaitRead(0xc82013f950, 0x0, 0x0) 
        /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 
net.(*netFD).accept(0xc82013f8f0, 0x0, 0x7fe0eeab0028, 0xc82037b800) 
        /usr/local/go/src/net/fd_unix.go:408 +0x27c 
net.(*TCPListener).AcceptTCP(0xc82012e070, 0xc82003adc0, 0x0, 0x0) 
        /usr/local/go/src/net/tcpsock_posix.go:254 +0x4d 
net.(*TCPListener).Accept(0xc82012e070, 0x0, 0x0, 0x0, 0x0) 
        /usr/local/go/src/net/tcpsock_posix.go:264 +0x3d 
net/http.(*Server).Serve(0xc8201c6000, 0x7fe0eeaf1110, 0xc82012e070, 0x0, 0x0) 
        /usr/local/go/src/net/http/server.go:1887 +0xb3 
net/http.Serve(0x7fe0eeaf1110, 0xc82012e070, 0x7fe0eeab0000, 0xc82013a6c0, 0x0, 0x0) 
        /usr/local/go/src/net/http/server.go:1765 +0x85 
github.com/influxdata/kapacitor/services/httpd.(*Service).serve.func1(0xc820138870) 
        /root/go/src/github.com/influxdata/kapacitor/services/httpd/service.go:114 +0x6e 
created by github.com/influxdata/kapacitor/services/httpd.(*Service).serve 
        /root/go/src/github.com/influxdata/kapacitor/services/httpd/service.go:122 +0x35 

goroutine 19 [select]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc8201accf0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*TaskMaster).runForking(0xc82016e420, 0xc8201accf0) 
        /root/go/src/github.com/influxdata/kapacitor/task_master.go:380 +0xcc 
created by github.com/influxdata/kapacitor.(*TaskMaster).stream 
        /root/go/src/github.com/influxdata/kapacitor/task_master.go:374 +0x14f 

goroutine 57 [runnable]: 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:85 +0x132 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 37 [chan receive]: 
github.com/influxdata/kapacitor/services/udp.(*Service).processPackets(0xc82027e280) 
        /root/go/src/github.com/influxdata/kapacitor/services/udp/service.go:143 +0xe6 
created by github.com/influxdata/kapacitor/services/udp.(*Service).Open 
        /root/go/src/github.com/influxdata/kapacitor/services/udp/service.go:105 +0xc84 

goroutine 36 [IO wait]: 
net.runtime_pollWait(0x7fe0eeaf1f10, 0x72, 0xc820010190) 
        /usr/local/go/src/runtime/netpoll.go:157 +0x60 
net.(*pollDesc).Wait(0xc8202488b0, 0x72, 0x0, 0x0) 
        /usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a 
net.(*pollDesc).WaitRead(0xc8202488b0, 0x0, 0x0) 
        /usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 
net.(*netFD).readFrom(0xc820248850, 0xc8202c8000, 0x10000, 0x10000, 0x0, 0x0, 0x0, 0x7fe0f0b34050, 0xc820010190) 
        /usr/local/go/src/net/fd_unix.go:259 +0x2a5 
net.(*UDPConn).ReadFromUDP(0xc820244038, 0xc8202c8000, 0x10000, 0x10000, 0x18f, 0x18f, 0x0, 0x0) 
        /usr/local/go/src/net/udpsock_posix.go:61 +0x117 
github.com/influxdata/kapacitor/services/udp.(*Service).serve(0xc82027e280) 
        /root/go/src/github.com/influxdata/kapacitor/services/udp/service.go:125 +0x166 
created by github.com/influxdata/kapacitor/services/udp.(*Service).Open 
        /root/go/src/github.com/influxdata/kapacitor/services/udp/service.go:103 +0xc39 

goroutine 61 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378570, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc820378570, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x4) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 60 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378300, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc820378300, 0x0, 0x0, 0x180001) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x3) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 59 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378090, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc820378090, 0x0, 0x0, 0x180001) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x2) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 58 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036fe00, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc82036fe00, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x1) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 8 [select]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc8203796e0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc8201047e0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8201047e0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 9 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820359560, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc820104900, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc820104900, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 10 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc8203597d0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8300, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8300, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 11 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820359a40, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc820105320, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc820105320, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 12 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820359cb0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f83c0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f83c0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 13 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820359f20, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc820105d40, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc820105d40, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 14 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036e1b0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8480, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8480, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 15 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036e420, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc82036c7e0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc82036c7e0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 16 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036e660, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8540, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8540, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 98 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036e8d0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc82036d200, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc82036d200, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 99 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036eb10, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8600, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8600, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 100 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036ed80, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc82036dc20, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc82036dc20, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 101 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036efc0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f86c0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f86c0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 102 [runnable]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036f230, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc8203746c0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8203746c0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 103 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036f470, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8780, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8780, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 104 [select]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036f6e0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*StreamNode).runStream(0xc8203750e0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:42 +0x308 
github.com/influxdata/kapacitor.(*StreamNode).(github.com/influxdata/kapacitor.runStream)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/stream.go:31 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8203750e0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 105 [select]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc82036f920, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*DerivativeNode).runDerivative(0xc8200f8840, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:31 +0x28b 
github.com/influxdata/kapacitor.(*DerivativeNode).(github.com/influxdata/kapacitor.runDerivative)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/derivative.go:23 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f8840, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 106 [semacquire, 1 minutes]: 
sync.runtime_Semacquire(0xc82026a53c) 
        /usr/local/go/src/runtime/sema.go:43 +0x26 
sync.(*WaitGroup).Wait(0xc82026a530) 
        /usr/local/go/src/sync/waitgroup.go:126 +0xb4 
github.com/influxdata/kapacitor.(*JoinNode).runJoin(0xc82009a700, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:89 +0x14f 
github.com/influxdata/kapacitor.(*JoinNode).(github.com/influxdata/kapacitor.runJoin)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:64 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc82009a700, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 107 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378f60, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*EvalNode).runEval(0xc8200eb5e0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/eval.go:41 +0xce 
github.com/influxdata/kapacitor.(*EvalNode).(github.com/influxdata/kapacitor.runEval)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/eval.go:34 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200eb5e0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 108 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820379200, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*EvalNode).runEval(0xc8200eb6c0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/eval.go:41 +0xce 
github.com/influxdata/kapacitor.(*EvalNode).(github.com/influxdata/kapacitor.runEval)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/eval.go:34 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200eb6c0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 109 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820379470, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*InfluxDBOutNode).runOut(0xc8200f1ee0, 0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/influxdb_out.go:29 +0xce 
github.com/influxdata/kapacitor.(*InfluxDBOutNode).(github.com/influxdata/kapacitor.runOut)-fm(0x0, 0x0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/influxdb_out.go:22 +0x4c 
github.com/influxdata/kapacitor.(*node).start.func1(0xc8200f1ee0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:95 +0x7f 
created by github.com/influxdata/kapacitor.(*node).start 
        /root/go/src/github.com/influxdata/kapacitor/node.go:96 +0x8d 

goroutine 110 [select]: 
github.com/influxdata/kapacitor.(*ExecutingTask).runSnapshotter(0xc820357650) 
        /root/go/src/github.com/influxdata/kapacitor/task.go:381 +0x845 
created by github.com/influxdata/kapacitor.(*ExecutingTask).start 
        /root/go/src/github.com/influxdata/kapacitor/task.go:184 +0x236 

goroutine 111 [chan receive, 1 minutes]: 
github.com/influxdata/kapacitor.(*node).Err(0xc8200f1ee0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/node.go:117 +0xc6 
github.com/influxdata/kapacitor.(*ExecutingTask).Err.func1(0x7fe0eeab0be8, 0xc8200f1ee0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/task.go:268 +0x33 
github.com/influxdata/kapacitor.(*ExecutingTask).rwalk(0xc820357650, 0xda50f0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/task.go:112 +0x91 
github.com/influxdata/kapacitor.(*ExecutingTask).Err(0xc820357650, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/task.go:269 +0x39 
github.com/influxdata/kapacitor/services/task_store.(*Service).StartTask.func1(0xc820357650, 0xc82013a720, 0xc82032af40) 
        /root/go/src/github.com/influxdata/kapacitor/services/task_store/service.go:613 +0x30 
created by github.com/influxdata/kapacitor/services/task_store.(*Service).StartTask 
        /root/go/src/github.com/influxdata/kapacitor/services/task_store/service.go:625 +0x271 

goroutine 62 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc8203787e0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc8203787e0, 0x0, 0x0, 0x180001) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x5) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 63 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378a50, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc820378a50, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x6) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 64 [select, 1 minutes]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820378cc0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*Edge).Next(0xc820378cc0, 0x0, 0x0, 0x0) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:113 +0x55 
github.com/influxdata/kapacitor.(*JoinNode).runJoin.func1(0xc82026a530, 0xc82009a700, 0x7) 
        /root/go/src/github.com/influxdata/kapacitor/join.go:79 +0x9b 
created by github.com/influxdata/kapacitor.(*JoinNode).runJoin 
        /root/go/src/github.com/influxdata/kapacitor/join.go:87 +0x12f 

goroutine 112 [select]: 
github.com/influxdata/kapacitor.(*Edge).NextPoint(0xc820379aa0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...) 
        /root/go/src/github.com/influxdata/kapacitor/edge.go:119 +0x17d 
github.com/influxdata/kapacitor.(*TaskMaster).runForking(0xc82016e420, 0xc820379aa0) 
        /root/go/src/github.com/influxdata/kapacitor/task_master.go:380 +0xcc 
created by github.com/influxdata/kapacitor.(*TaskMaster).stream 
        /root/go/src/github.com/influxdata/kapacitor/task_master.go:374 +0x14f 

goroutine 113 [select]: 
github.com/influxdata/kapacitor/services/stats.(*Service).sendStats(0xc820135b80) 
        /root/go/src/github.com/influxdata/kapacitor/services/stats/service.go:100 +0x179 
created by github.com/influxdata/kapacitor/services/stats.(*Service).Open 
        /root/go/src/github.com/influxdata/kapacitor/services/stats/service.go:76 +0x1fa 

goroutine 114 [chan receive, 1 minutes]: 
github.com/influxdata/kapacitor/cmd/kapacitord/run.(*Server).Open.func2(0xc820131d00) 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/run/server.go:444 +0x69 
created by github.com/influxdata/kapacitor/cmd/kapacitord/run.(*Server).Open 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/run/server.go:447 +0x8f 

goroutine 115 [select, 1 minutes]: 
github.com/influxdata/kapacitor/cmd/kapacitord/run.(*Command).monitorServerErrors(0xc82016a000) 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/run/command.go:147 +0x289 
created by github.com/influxdata/kapacitor/cmd/kapacitord/run.(*Command).Run 
        /root/go/src/github.com/influxdata/kapacitor/cmd/kapacitord/run/command.go:127 +0x1314 

goroutine 116 [select, 1 minutes, locked to thread]: 
runtime.gopark(0xda5d50, 0xc82038d728, 0xc42d40, 0x6, 0x18, 0x2) 
        /usr/local/go/src/runtime/proc.go:185 +0x163 
runtime.selectgoImpl(0xc82038d728, 0x0, 0x18) 
        /usr/local/go/src/runtime/select.go:392 +0xa64 
runtime.selectgo(0xc82038d728) 
        /usr/local/go/src/runtime/select.go:212 +0x12 
runtime.ensureSigM.func1() 
        /usr/local/go/src/runtime/signal1_unix.go:227 +0x353 
runtime.goexit() 
        /usr/local/go/src/runtime/asm_amd64.s:1721 +0x1
@naude-r
Copy link

naude-r commented Mar 16, 2016

Kapacitor 0.10.1 (git: master 22b917b)

@nathanielc
Copy link
Contributor Author

@naude-r Thanks, this section of code has been significantly updated, could you try and reproduce the error using the nightly build which can be found here https://influxdata.com/downloads/

@jonseymour
Copy link
Contributor

I have a test case that produces a similar symptom:

var metric1 = stream
    |from()
        .database('sampledb')
        .retentionPolicy('default')
        .measurement('sample')
    |window()
        .align()
        .period(5m)
        .every(5m)
    |groupBy('node')
    |mean('metric1').as('metric1')


var metric2 = stream
    |from()
        .database('sampledb')
        .retentionPolicy('default')
        .measurement('sample')
    |window()
        .align()
        .period(5m)
        .every(5m)
    |groupBy('node')
    |mean('metric2').as('metric2')

metric1
    |join(metric2)
    |log()

Produces this panic:

panic: runtime error: index out of range

goroutine 198 [running]:
panic(0xbffc80, 0xc820010030)
    /usr/local/go/src/runtime/panic.go:464 +0x3e6
github.com/influxdata/kapacitor.(*group).collect(0xc8201d22d0, 0x0, 0x7f9d78a385e8, 0xc8201a0080, 0x0, 0x0)
    /root/go/src/github.com/influxdata/kapacitor/join.go:293 +0x7d7
github.com/influxdata/kapacitor.(*group).run(0xc8201d22d0, 0x0, 0x0)
    /root/go/src/github.com/influxdata/kapacitor/join.go:272 +0x117
github.com/influxdata/kapacitor.(*JoinNode).getGroup.func1(0xc8201d22d0, 0xc820219b00, 0xc828782180)
    /root/go/src/github.com/influxdata/kapacitor/join.go:231 +0x30
created by github.com/influxdata/kapacitor.(*JoinNode).getGroup
    /root/go/src/github.com/influxdata/kapacitor/join.go:239 +0x2db

This is on Kapacitor 0.12.

The test case can be found in tests/issue-331 in https://github.com/wildducktheories/influxdata-testcase

@jonseymour
Copy link
Contributor

@nathanielc @naude-r I rectified the error in my case by changing my script from:

metric1
    |join(metric2)
    |log()

to:

metric1
    |join(metric2)
        .as('metric1', 'metric2')
    |log()

that is, by adding prefixes for each arm of the join

jonseymour added a commit to jonseymour/kapacitor that referenced this issue Apr 8, 2016
@jonseymour
Updated CHANGELOG for issue influxdata#331.
4d01f21
This was referenced Apr 8, 2016
Closed
Closed
jonseymour added a commit to jonseymour/kapacitor that referenced this issue Apr 9, 2016
@jonseymour
Updated CHANGELOG for issue influxdata#331.
da14cd5
@jonseymour jonseymour mentioned this issue Apr 9, 2016
Closed
jonseymour added a commit to jonseymour/kapacitor that referenced this issue Apr 9, 2016
@jonseymour
PR influxdata#431: Move some join node validations from runtime to de…
cdc24a1 
…finition time.

Assuming the acceptance of PR influxdata#443, some validations previously performed
at runtime can now be performed at definition time.

The existing validations are moved into the pipeline.JoinNode type.

The validations are extended to resolve the panic reported in issue influxdata#331.

Signed-off-by: Jon Seymour <jon@wildducktheories.com>
jonseymour added a commit to jonseymour/kapacitor that referenced this issue Apr 13, 2016
@jonseymour
PR influxdata#431: Move some join node validations from runtime to de…
13131c3 
…finition time.

Assuming the acceptance of PR influxdata#443, some validations previously performed
at runtime can now be performed at definition time.

The existing validations are moved into the pipeline.JoinNode type.

The validations are extended to resolve the panic reported in issue influxdata#331.

Signed-off-by: Jon Seymour <jon@wildducktheories.com>
nathanielc pushed a commit that referenced this issue May 4, 2016
@jonseymour @nathanielc
PR #431: Move some join node validations from runtime to definition t…
91ff3e6 
…ime.

Assuming the acceptance of PR #443, some validations previously performed
at runtime can now be performed at definition time.

The existing validations are moved into the pipeline.JoinNode type.

The validations are extended to resolve the panic reported in issue #331.

Signed-off-by: Jon Seymour <jon@wildducktheories.com>
@nathanielc nathanielc mentioned this issue May 4, 2016
Merged
nathanielc pushed a commit that referenced this issue May 5, 2016
Fix panic on JoinNode missing .as() (#509)
85512c3 
* PR #431: Move some join node validations from runtime to definition time.

Assuming the acceptance of PR #443, some validations previously performed
at runtime can now be performed at definition time.

The existing validations are moved into the pipeline.JoinNode type.

The validations are extended to resolve the panic reported in issue #331.

Signed-off-by: Jon Seymour <jon@wildducktheories.com>

* CHANGELOG.md
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
3 participants
@jonseymour @naude-r @nathanielc