fixing stats join tables

db7 · Dec 1, 2017 · a2986e8 · a2986e8
1 parent 584cf86
commit a2986e8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/processor.go b/processor.go
@@ -738,6 +738,9 @@ func (g *Processor) Stats() *ProcessorStats {
 		stats.Group[i] = p.fetchStats()
 	}
 	for i, p := range g.partitionViews {
+		if _, ok := stats.Joined[i]; !ok {
+			stats.Joined[i] = make(map[string]*PartitionStats)
+		}
 		for t, tp := range p {
 			stats.Joined[i][t] = tp.fetchStats()
 		}