From f4810819049ae892d92abd903fb9bde4b129e53b Mon Sep 17 00:00:00 2001
From: Tao Wang <dooku.wt@antfin.com>
Date: Wed, 1 Dec 2021 15:48:21 +0800
Subject: [PATCH] [Java]Get next job id only in driver (#20813)

## Why are these changes needed?
Job id is only used in driver, we should not get it in WORKER.
---
 java/runtime/src/main/java/io/ray/runtime/RayNativeRuntime.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/java/runtime/src/main/java/io/ray/runtime/RayNativeRuntime.java b/java/runtime/src/main/java/io/ray/runtime/RayNativeRuntime.java
index cbe866b63..23516604e 100644
--- a/java/runtime/src/main/java/io/ray/runtime/RayNativeRuntime.java
+++ b/java/runtime/src/main/java/io/ray/runtime/RayNativeRuntime.java
@@ -96,7 +96,7 @@ public final class RayNativeRuntime extends AbstractRayRuntime {
         rayConfig.nodeManagerPort = nodeInfo.getNodeManagerPort();
       }
 
-      if (rayConfig.getJobId() == JobId.NIL) {
+      if (rayConfig.workerMode == WorkerType.DRIVER && rayConfig.getJobId() == JobId.NIL) {
         rayConfig.setJobId(gcsClient.nextJobId());
       }
       int numWorkersPerProcess =