mirror of
https://github.com/wassname/ray.git
synced 2026-10-05 13:10:07 +08:00
[Java] Destroy native core worker before killing ray processes (#5516)
This commit is contained in:
1 parent
d2a6f7958a
commit
53fd66f6d6
1 file changed
+3
-3
@@ -131,13 +131,13 @@ public final class RayNativeRuntime extends AbstractRayRuntime {
|
||||
|
||||
@Override
|
||||
public void shutdown() {
|
||||
if (null != manager) {
|
||||
manager.cleanup();
|
||||
}
|
||||
if (nativeCoreWorkerPointer != 0) {
|
||||
nativeDestroyCoreWorker(nativeCoreWorkerPointer);
|
||||
nativeCoreWorkerPointer = 0;
|
||||
}
|
||||
if (null != manager) {
|
||||
manager.cleanup();
|
||||
}
|
||||
}
|
||||
|
||||
public void run() {
|
||||
|
||||
Reference in new issue
Block a user