apache / rocketmq-streams

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

[ISSUE #270]polish double stream join #269

Closed ni-ze closed 1 year ago

ni-ze commented 1 year ago
  1. fix join operator bug, the common topology operator build at last.
  2. share the scheduled executor between workerThread;
  3. fix the key of join result;

close #270

codecov-commenter commented 1 year ago

Codecov Report

Merging #269 (c81b551) into develop (b5355de) will not change coverage. The diff coverage is 0.00%.

@@           Coverage Diff           @@
##           develop    #269   +/-   ##
=======================================
  Coverage     0.00%   0.00%           
=======================================
  Files           88      89    +1     
  Lines         3084    3132   +48     
  Branches       304     313    +9     
=======================================
- Misses        3084    3132   +48     
Impacted Files Coverage Δ
...g/apache/rocketmq/streams/core/RocketMQStream.java 0.00% <0.00%> (ø)
...q/streams/core/function/supplier/SinkSupplier.java 0.00% <0.00%> (ø)
...e/rocketmq/streams/core/metadata/StreamConfig.java 0.00% <0.00%> (ø)
...apache/rocketmq/streams/core/rstream/Pipeline.java 0.00% <0.00%> (ø)
...e/rocketmq/streams/core/rstream/StreamBuilder.java 0.00% <0.00%> (ø)
.../streams/core/running/AbstractWindowProcessor.java 0.00% <ø> (ø)
.../rocketmq/streams/core/running/RocketMQClient.java 0.00% <0.00%> (ø)
...he/rocketmq/streams/core/running/WorkerThread.java 0.00% <0.00%> (ø)
...che/rocketmq/streams/core/state/AbstractStore.java 0.00% <0.00%> (ø)
...che/rocketmq/streams/core/state/RocketMQStore.java 0.00% <ø> (ø)
... and 10 more

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more