-
Notifications
You must be signed in to change notification settings - Fork 134
IGNITE-18625 Sql. Code cleanup. Unmute tests. #1590
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
Conversation
d5158fd to
5eb8aff
Compare
5eb8aff to
a9548c4
Compare
f54dab9 to
3b23f93
Compare
...les/runner/src/integrationTest/java/org/apache/ignite/internal/index/ItIndexManagerTest.java
Outdated
Show resolved
Hide resolved
modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItDmlTest.java
Show resolved
Hide resolved
| } | ||
| }) | ||
| ).join(); | ||
| compPublisher.subscribe(new Subscriber<>() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please return back runAsync here, it requeres for the test
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think all the guaranties are preserved.
Test thread would continue work (exit from join()) right after subscribe() method had been finished in background thread.
Now, test thread just continue after exiting from subscribe() method.
zstan
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks great
No description provided.