Merge pull request #12 from RuiFG/master

fix: union operator emit be nil
RuiFG · Jan 9, 2023 · 660a956 · 660a956
2 parents e70c5b2 + eac022d
commit 660a956
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/streaming-operator/union/union.go b/streaming-operator/union/union.go
@@ -44,6 +44,7 @@ func (o *operator[T]) Open(ctx Context, emit element.Emit) error {
 			return err
 		}
 	}
+	o.emit = emit
 	o.combineWatermark = NewCombineWatermark(o.inputCount)
 	return nil
 }