diff --git a/java/runtime/src/main/java/org/ray/runtime/RayNativeRuntime.java b/java/runtime/src/main/java/org/ray/runtime/RayNativeRuntime.java index ab1b6d0b7..c15a87033 100644 --- a/java/runtime/src/main/java/org/ray/runtime/RayNativeRuntime.java +++ b/java/runtime/src/main/java/org/ray/runtime/RayNativeRuntime.java @@ -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() {