diff --git a/internal/util/flowgraph/flow_graph.go b/internal/util/flowgraph/flow_graph.go index a77a76ffba..170050c3f5 100644 --- a/internal/util/flowgraph/flow_graph.go +++ b/internal/util/flowgraph/flow_graph.go @@ -29,7 +29,6 @@ func (fg *TimeTickedFlowGraph) AddNode(node Node) { nodeName := node.Name() nodeCtx := nodeCtx{ node: node, - inputChannels: make([]chan Msg, 0), downstreamInputChanIdx: make(map[string]int), closeCh: make(chan struct{}), }