Close span writer

Signed-off-by: Davit Yeghshatyan <davo@uber.com>
jaegertracing · Jul 30, 2018 · 79a55d6 · 79a55d6
1 parent 5cdfb87
commit 79a55d6
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/cmd/ingester/main.go b/cmd/ingester/main.go
@@ -16,6 +16,7 @@ package main
 
 import (
 	"fmt"
+	"io"
 	"log"
 	"os"
 	"os/signal"
@@ -99,7 +100,13 @@ func main() {
 			case <-signalsChannel:
 				err := kafkaConsumer.Close()
 				if err != nil {
-					logger.Error("Failed to close span writer", zap.Error(err))
+					logger.Error("Failed to close consumer", zap.Error(err))
+				}
+				if closer, ok := spanWriter.(io.Closer); ok {
+					err := closer.Close()
+					if err != nil {
+						logger.Error("Failed to close span writer", zap.Error(err))
+					}
 				}
 				logger.Info("Jaeger Ingester is finishing")
 			}