Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
Hi
I have two jobs and each of these jobs are getting messages from Kafka topic and pushing into DB. These jobs terminate when there are no messages on kafka topic after 10 secs. Individually both these jobs works as expected. Now I have created a main job that simply calls these jobs in sequence tJob1 - tJob2. When I run this main job I expect the job to terminate automatically after 20 secs if no messages on topic. But this main job keeps running for 6 mins before terminating. Any pointers?
Starting job I900_901_Plan_Main at 11:35 11/12/2019.
[statistics] connecting to socket on port 3815
[statistics] connected
tRunJob_1 in I900_901_Plan_Main call mars_project.test_consume_job_0_1.test_consume_job with:
[--father_pid=enEB33, --root_pid=enEB33, --father_node=tRunJob_1, --context=Default, --stat_port=3815, --parent_part_launcher=JOB:I900_901_Plan_Main/NODE:tRunJob_1]
tRunJob_2 in I900_901_Plan_Main call mars_project.test_consume_job2_0_1.test_consume_job2 with:
[--father_pid=enEB33, --root_pid=enEB33, --father_node=tRunJob_2, --context=Default, --stat_port=3815, --parent_part_launcher=JOB:I900_901_Plan_Main/NODE:tRunJob_2]
312957 milliseconds
[statistics] disconnected
Job I900_901_Plan_Main ended at 11:41 11/12/2019. [exit code=0]
Hi,
I am not pretty sure about this behavior. Lets check with @xdshi
Warm Regards,
Nikhil Thampi
Please appreciate our Talend community members by giving Kudos for sharing their time for your query. If your query is answered, please mark the topic as resolved