diff --git a/java/runtime/src/main/java/io/ray/runtime/task/NativeTaskSubmitter.java b/java/runtime/src/main/java/io/ray/runtime/task/NativeTaskSubmitter.java index eba97f1fb..5443410e5 100644 --- a/java/runtime/src/main/java/io/ray/runtime/task/NativeTaskSubmitter.java +++ b/java/runtime/src/main/java/io/ray/runtime/task/NativeTaskSubmitter.java @@ -34,7 +34,7 @@ public class NativeTaskSubmitter implements TaskSubmitter { @Override public BaseActorHandle createActor(FunctionDescriptor functionDescriptor, List args, ActorCreationOptions options) throws IllegalArgumentException { - if (StringUtils.isNotBlank(options.name)) { + if (options != null && StringUtils.isNotBlank(options.name)) { Optional actor = options.global ? Ray.getGlobalActor(options.name) : Ray.getActor(options.name); Preconditions.checkArgument(!actor.isPresent(),