Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ISSUE #270]polish double stream join #269

Merged
merged 13 commits into from
Feb 14, 2023
Merged

[ISSUE #270]polish double stream join #269

merged 13 commits into from
Feb 14, 2023

Conversation

ni-ze
Copy link
Contributor

@ni-ze ni-ze commented Feb 10, 2023

  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

@ni-ze ni-ze changed the title polish double stream join [ISSUE #270]polish double stream join Feb 10, 2023
@codecov-commenter
Copy link

codecov-commenter commented Feb 10, 2023

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

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

@ni-ze ni-ze merged commit 9bff38e into apache:develop Feb 14, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

polish double stream join
2 participants