[
https://issues.apache.org/jira/browse/IGNITE-27686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18054879#comment-18054879
]
Tiago Marques Godinho commented on IGNITE-27686:
------------------------------------------------
The same is true for the results marsheller
> Misleading error message in compute job execution
> -------------------------------------------------
>
> Key: IGNITE-27686
> URL: https://issues.apache.org/jira/browse/IGNITE-27686
> Project: Ignite
> Issue Type: Improvement
> Components: compute ai3
> Reporter: Tiago Marques Godinho
> Priority: Major
> Labels: ignite-3
>
> Got the following exception: "Marshaller should be defined on the client"
>
> {code:java}
> Marshaller should be defined on the client
> org.apache.ignite.compute.ComputeException: IGN-COMPUTE-13 Marshaller should
> be defined on the client TraceId:b0adc15f
> at
> org.apache.ignite.internal.compute.SharedComputeUtils.unmarshalArgOrResult(SharedComputeUtils.java:206)
> at
> org.apache.ignite.internal.compute.ComputeUtils.unmarshalOrNotIfNull(ComputeUtils.java:383)
> at
> org.apache.ignite.internal.compute.executor.ComputeExecutorImpl.lambda$unmarshalExecMarshal$3(ComputeExecutorImpl.java:231)
> at
> org.apache.ignite.internal.compute.executor.ComputeExecutorImpl.lambda$addObservableTimestamp$1(ComputeExecutorImpl.java:158)
> at
> org.gridgain.internal.security.context.SecuredCallable.call(SecuredCallable.java:35)
> at
> org.apache.ignite.internal.compute.queue.QueueExecutionImpl.lambda$run$0(QueueExecutionImpl.java:182)
> at
> org.apache.ignite.internal.compute.queue.QueueEntry.run(QueueEntry.java:73)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> {code}
> When executing the compute job with:
>
>
> {code:java}
> String r = ign.compute().execute(
> JobTarget.node(ign.cluster().localNode()),
> JobDescriptor.builder(BootstrapJob.class)
> .argumentMarshaller(ByteArrayMarshaller.create())
> .build(),
> new BootstapJobArgs("", new String[] {
> "compute-jobs", VERSION.render()
> })
> ); {code}
> The message is misleading as it points to the client, but the actual problem
> is in the compute job definition (class). It does not override the
> marshallers with:
> {code:java}
> @Override
> @Nullable
> public Marshaller<BootstapJobArgs, byte[]> inputMarshaller() {
> return ByteArrayMarshaller.create();
> } {code}
> *What to do:*
> * Improve the exception so that it's clear that the error happens because no
> marshaller is defined in the compute job class.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
