From a2986e8a6c7ed2e7ca87b9fabeee5817dc78d91a Mon Sep 17 00:00:00 2001
From: Diogo Behrens <diogo.behrens@lovoo.com>
Date: Fri, 1 Dec 2017 14:40:45 +0100
Subject: [PATCH] fixing stats join tables

---
 processor.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/processor.go b/processor.go
index e8e96eee..52606e67 100644
--- 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()
 		}