Skip to content

Commit 1f745f8

Browse files
committed
IGNITE-25910 Refactor GridJobExecuteRequest
1 parent 4d2b08d commit 1f745f8

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1275,8 +1275,11 @@ public void processJobExecuteRequest(ClusterNode node, final GridJobExecuteReque
12751275
GridJobSessionImpl jobSes;
12761276
GridJobContextImpl jobCtx;
12771277

1278+
boolean loc = ctx.localNodeId().equals(node.id()) && !ctx.config().isMarshalLocalJobs();
1279+
12781280
try {
1279-
req.finishUnmarshal(marsh, U.resolveClassLoader(dep.classLoader(), ctx.config()));
1281+
if (!loc)
1282+
req.finishUnmarshal(marsh, U.resolveClassLoader(dep.classLoader(), ctx.config()));
12801283

12811284
// Note that we unmarshal session/job attributes here with proper class loader.
12821285
GridTaskSessionImpl taskSes = ctx.session().createTaskSession(

0 commit comments

Comments
 (0)