topic Re: using tCheckpoint in multi thread job in Talend Studio

using tCheckpoint in multi thread job

Fahad2 — Fri, 02 Jan 2026 14:45:42 GMT

Hi!

I am trying to use tCheckpoint (a third party component) in Multi Thread Execution. Attached is a demo job.

Job Description:

What I am doing is;

In tPrejob, establishing a DB connection (using Teradata DB).
Executing parallel jobs using tCheckpoints with some dummy jobs.
From tStatcCatcher, I am looking up for any component with a "failure" message and then setting a key "CP_End" in globalMap to log a value that shows if any of the component suffered a failure and checkpoint file is cleared in tPostJob.

in tPreJob, tJava is just to use an if trigger. In if trigger, "CP_End" is checked for value. if it exists then it means there was some error and checkpoint file is not cleared. In case of flawless execution, checkpoint file is cleared.

Issue:

When I generate an error in tDBInput_1, the job is expected to execute CP2 only and not the rest of sub jobs. However, CP3 gets executed where error is not generated even. Below is demo of such execution.

Respective Checkpoint file.

2- Re-executing job.

An interesting fact is that this job was functioning correctly when I designed it few days ago and I checked all scenarios. I have not changed any configuration since then. I am using TOS 7.21. Any help will be greatly appreciated. 🙂

Regards,

Fahad.

Re: using tCheckpoint in multi thread job

Fahad2 — Mon, 10 Aug 2020 08:31:52 GMT

Here is the checkpoint status upon re-execution

Checkpoint1

CP1 Recovery: false

CP1 Execution: false

Checkpoint2

CP2 Recovery: false

CP2 Execution: false

Checkpoint3

CP3 Recovery: true

CP3 Execution: true

The run if triggers from CPs comprise of ((Boolean)globalMap.get("tCheckpoint_xxx_NEEDS_EXECUTION")) only.

Also, I have used Checkpoints in sequential execution and everything works as per requirement, I am facing trouble only in multi thread execution.

Re: using tCheckpoint in multi thread job

Anonymous — Mon, 10 Aug 2020 08:47:53 GMT

@Not defined Not defined , if you want to compare whether two string are equal, use the String1.equals("string2") function replace of "=" in the Java expression, eg:

if(input_row.message.equals("failure")){

....

}

Regards

Shong

Re: using tCheckpoint in multi thread job

Fahad2 — Mon, 10 Aug 2020 09:07:21 GMT

Hi Shong!

I have replaced "==" with ".equals", however, I am still facing same issue with checkpoints.