diff --git a/internal/query/projection/projection.go b/internal/query/projection/projection.go index e6f9c64b01..6afe658cc3 100644 --- a/internal/query/projection/projection.go +++ b/internal/query/projection/projection.go @@ -210,7 +210,14 @@ func Init(ctx context.Context) error { } func Start(ctx context.Context) { + projectionTableMap := make(map[string]bool, len(projections)) for _, projection := range projections { + table := projection.String() + if projectionTableMap[table] { + panic("projeciton for " + projection.String() + " already added") + } + projectionTableMap[table] = true + projection.Start(ctx) } }