Print

[hoho23]

Hello JPPF Community,

I am working on a project that needs to execute specific code snippet before executing some jobs, the code snippet to execute depends on the job metadata. For that, I am using a NodeLifeCycleListenerAdapater, then overriding the jobHeadLoaded(final NodeLifeCycleEvent event) method, on which I try to get the metadata parameter which is a Runnable object that contains the code to execute. Unfortunately, the connection I lose the connection to the class server and the task server. I think the problem is caused by passing a runnable object as a parameter through the job metadata, since it works with other types of object such as String object. I need your help to know if there is a method to pass a runnable as a parameter on the job metadata, or if there is another option to do it using some jppf tools.
Below the error code I get, it would be helpful.

Code: [Select]

2021-03-26 11:43:51,425 - [ForkJoinPool.commonPool-worker-3] - INFO  - org.my.package.Main - Do JPPF distributed task
[client: jppf_discovery-1-1 - ClassServer] Attempting connection to the class server at address:port
[client: jppf_discovery-1-1 - ClassServer] Reconnected to the class server
[client: jppf_discovery-1-1 - TasksServer] Attempting connection to the task server at address:port
[client: jppf_discovery-1-1 - TasksServer] Reconnected to the JPPF task server
[client: jppf_discovery-1-1 - ClassServer] Attempting connection to the class server at address:port
[client: jppf_discovery-1-1 - ClassServer] Reconnected to the class server
[client: jppf_discovery-1-1 - TasksServer] Attempting connection to the task server at address:port
[client: jppf_discovery-1-1 - TasksServer] Reconnected to the JPPF task server
Thank you,
hoho23

[lolo]

Hello,

Did you ensure that your Runnable object is also Serializable? If not, this could explain the disconnection problem when you submit the job.

I hope this helps,
-Laurent

[hoho23]

Yes, it's serializable. I'am using a SerializableRunnable object, Here is the code:

Code: [Select]

JPPFJob jppfJob = new JPPFJob();
JobMetadata metadata = jppfJob.getMetadata();
metadata.setParameter(1, "hey");
SerializableRunnable runnable =()-> {
System.err.println(" I am the runnable! ");
};
metadata.setParameter(2, runnable);

[lolo]

Hello,

Thank you for the vital information you provided. I believe this is a class loading issue with regards to your NodeLifeCycleListener. By design, in the jobHeaderLoaded() method, the class loader used does not have access to the classes in the classpath of the JPPF client. It can only access classes in the driver's or node's classpath. Here, you're using a SerializableRunnable, which is not part of the JPPF API, and thus is probably only in tour client classpath. In the log of the node where it happens, you should see a ClassNotFoundException, can you check this?

Also, as an experiment, could you try not using SerializableRunnable and instead use the following lambda construct, which only refers to JDK interfaces:

Code: [Select]

Runnable runnable = (Serializable & Runnable) () -> System.err.println(" I am the runnable! ");
Could you please try that and let us know if this works?

Sincerely,
-Laurent

[hoho23]

I tried to replace my code snippet with the code you sent below, but it still not working.

Code: [Select]

Runnable runnable = (Serializable & Runnable) () -> System.err.println(" I am the runnable! ");I have always the same problem!
I also tried to copy the jar file of the external lib I am using (the one that contains the SerializableRunnable) in the lib directory of the driver and the problem always exists.
tell me if you need any additional information that can help to solve this problem, and I am really grateful for your help!

regards,
hoho23

[hoho23]

The problem is solved 
Actually, it was a dependency issue and now it works well.
Thank you for your help and explanation Mr. Laurent !