bugfix: series table stops uploading into clickhouse after error

go-graphite · Mar 21, 2018 · 84df778 · 84df778
1 parent 0a4209c
commit 84df778
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/uploader/cached.go b/uploader/cached.go
@@ -57,10 +57,14 @@ func (u *cached) upload(exit chan struct{}, logger *zap.Logger, filename string)
 	uploadResult := make(chan error, 1)
 
 	u.Go(func(exit chan struct{}) {
-		uploadResult <- u.insertRowBinary(
+		err := u.insertRowBinary(
 			u.insertQuery,
 			pipeReader,
 		)
+		uploadResult <- err
+		if err != nil {
+			pipeReader.CloseWithError(err)
+		}
 	})
 
 	newSeries, err := u.parser(filename, writer)