From 087571b54a567b6215a5bea862f18481829a0388 Mon Sep 17 00:00:00 2001 From: Vivek Menezes Date: Sun, 12 Mar 2017 20:55:41 -0400 Subject: [PATCH] distsqlrun: remove redundant Close() Close() is already called when timedOut is set. fixes #13989 --- pkg/sql/distsqlrun/flow_registry.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/pkg/sql/distsqlrun/flow_registry.go b/pkg/sql/distsqlrun/flow_registry.go index 9eee45214d3f..a5d9ceee5d8e 100644 --- a/pkg/sql/distsqlrun/flow_registry.go +++ b/pkg/sql/distsqlrun/flow_registry.go @@ -270,10 +270,6 @@ func (fr *flowRegistry) finishInboundStreamLocked(is *inboundStreamInfo) { panic("double finish") } - if is.timedOut { - is.receiver.Close(errors.Errorf("inbound stream timed out")) - } - is.finished = true is.waitGroup.Done() }