diff --git a/java/api/src/main/java/org/ray/api/exception/RayActorException.java b/java/api/src/main/java/org/ray/api/exception/RayActorException.java index 42ac9d408..4137d03cf 100644 --- a/java/api/src/main/java/org/ray/api/exception/RayActorException.java +++ b/java/api/src/main/java/org/ray/api/exception/RayActorException.java @@ -8,9 +8,8 @@ package org.ray.api.exception; */ public class RayActorException extends RayException { - public static final RayActorException INSTANCE = new RayActorException(); - - private RayActorException() { + public RayActorException() { super("The actor died unexpectedly before finishing this task."); } + } diff --git a/java/api/src/main/java/org/ray/api/exception/RayWorkerException.java b/java/api/src/main/java/org/ray/api/exception/RayWorkerException.java index 512cca614..b089bd9f3 100644 --- a/java/api/src/main/java/org/ray/api/exception/RayWorkerException.java +++ b/java/api/src/main/java/org/ray/api/exception/RayWorkerException.java @@ -5,9 +5,8 @@ package org.ray.api.exception; */ public class RayWorkerException extends RayException { - public static final RayWorkerException INSTANCE = new RayWorkerException(); - - private RayWorkerException() { + public RayWorkerException() { super("The worker died unexpectedly while executing this task."); } + } diff --git a/java/runtime/src/main/java/org/ray/runtime/object/ObjectSerializer.java b/java/runtime/src/main/java/org/ray/runtime/object/ObjectSerializer.java index f386ae5c0..fe89ba428 100644 --- a/java/runtime/src/main/java/org/ray/runtime/object/ObjectSerializer.java +++ b/java/runtime/src/main/java/org/ray/runtime/object/ObjectSerializer.java @@ -45,9 +45,9 @@ public class ObjectSerializer { if (Arrays.equals(meta, RAW_TYPE_META)) { return data; } else if (Arrays.equals(meta, WORKER_EXCEPTION_META)) { - return RayWorkerException.INSTANCE; + return new RayWorkerException(); } else if (Arrays.equals(meta, ACTOR_EXCEPTION_META)) { - return RayActorException.INSTANCE; + return new RayActorException(); } else if (Arrays.equals(meta, UNRECONSTRUCTABLE_EXCEPTION_META)) { return new UnreconstructableException(objectId); } else if (Arrays.equals(meta, TASK_EXECUTION_EXCEPTION_META)) {