-
Notifications
You must be signed in to change notification settings - Fork 6k
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
[Java] Single-process mode #4245
Conversation
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.
Some code doesn't seem to be well formatted. you can run mvn checkstyle:check
locally to find lint problems.
} | ||
} | ||
|
||
@Override | ||
public byte[] get(byte[] objectId, int timeoutMs, boolean isMetadata) { | ||
return new byte[0]; |
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.
Forgot to fix this?
// ---------------------------- | ||
// configurations under SINGLE_PROCESS mode | ||
// ---------------------------- | ||
dev-runtime{ |
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.
space before {
@Override | ||
public void beforeEachCase() { | ||
TestUtils.skipTestUnderSingleProcess(); | ||
} |
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.
This test should work under single-process mode
@Override | ||
public void beforeEachCase() { | ||
TestUtils.skipTestUnderSingleProcess(); | ||
} |
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.
This should also work.
@@ -196,6 +201,9 @@ public RayConfig(Config config) { | |||
driverResourcePath = null; | |||
} | |||
|
|||
// number of threads that execute tasks under SINGLE_PROCESS mode |
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.
// number of threads that execute tasks under SINGLE_PROCESS mode | |
// Number of threads that execute tasks under SINGLE_PROCESS mode. |
Also apply to other places.
java/test.sh
Outdated
mvn test | tee mvn_test | ||
if [ `grep -c "BUILD FAILURE" mvn_test` -eq '0' ]; then | ||
rm mvn_test | ||
echo "Run well with CLUSTER mode!" |
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.
echo "Run well with CLUSTER mode!" | |
echo "Tests passed under CLUSTER mode!" |
Test FAILed. |
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.
LGTM
Test FAILed. |
Test FAILed. |
Test FAILed. |
@raulchen please help review
What do these changes do?
2.complete methods under single process mode such as:
submitTask
wait
freePlasma
3.add mvn test -Dray.run-mode=SINGLE_PROCESS in test.sh
Related issue number