search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

Fix npe two streams & fix joinwindow's production donot be conducted by mainpipeline's following stages #104

Closed lizhiboo closed 2 years ago

lizhiboo commented 2 years ago
  1. fix npe in two streams case. set otherPipelineBuilders.
  2. init otherPipelines at first to avoid miss mainPipeline's following stages after windowStage.