-
Notifications
You must be signed in to change notification settings - Fork 286
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
pipeline: let sorter node report resolved ts #3029
Conversation
Decouples reporting resolved ts from flow control (sorter -> sink). It makes flow control flexible, and makes possiable to implement a global flow control (sorter -> sink) mechanism. Signed-off-by: Neil Shen <overvenus@gmail.com>
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by submitting an approval review. |
/run-integration-tests |
Will this PR be cherry-picked to release branches? |
Signed-off-by: Neil Shen <overvenus@gmail.com>
Signed-off-by: Neil Shen <overvenus@gmail.com>
Signed-off-by: Neil Shen <overvenus@gmail.com>
@liuzix PTAL, thanks! |
This reverts commit c085d67.
Signed-off-by: Neil Shen <overvenus@gmail.com>
/merge |
This pull request has been accepted and is ready to merge. Commit hash: 5afff2a
|
/merge |
Codecov Report
@@ Coverage Diff @@
## master #3029 +/- ##
================================================
- Coverage 57.2251% 56.7156% -0.5095%
================================================
Files 163 203 +40
Lines 19453 22306 +2853
================================================
+ Hits 11132 12651 +1519
- Misses 7261 8363 +1102
- Partials 1060 1292 +232 |
What problem does this PR solve?
Decouples reporting resolved ts from flow control (sorter -> sink).
It makes flow control flexible, and makes possiable to implement a
global flow control (sorter -> sink) mechanism.
Cc #2561
Check List
Tests
Release note