[resolved] ,Step by Step Scheduler

[chandu282003]

Dear Talend Team,

i am using TIS 4.2 version , i have added new task in my job as Scheduler , i have given date / time , but after some it i thought the job was execute automatically , but it?s not executing , can you please let me know how i can process my job automatically based on given time and date.
Please help on this. Please find attached document which is having screens.


Regards
Chandu Mahanthy.

[shong · Accepted solution]

Hi we are using TIS but, we unable to schedule the jobs in talend. we want to do itself in talend scheduler.
Whenever we give all the parameter as job name,date,time and save it as .txt format, but the job does not start. would any body please help if any thing we are missing.

The scheduler inside studio is not available. To schedule the jobs, you should open the Talend Administrator Center(TAC) and schedule it on Job conductor.
Best regards
Shong

[chandu282003]

Hi Shong,.
Can you please help me on this , this is very important dear talend team.
Regards
Chandu

[shong]

Hi
To schedule the job, you should use the Job conductor feature in Talend Administrator Center, please read the user guide, TalendAdministrationCenter_xxx_UG_xxx_EN.pdf, chapter 3 Job Condutor.
The scheduler tab in studio is useless so far.
Let me know if you have any trouble to schedule a job on Job Condutor.
Best regards
Shong

[chandu282003]

Hi Shong,
i have done with below steps , getting some error , please find the errors below and attached screens , the job also i am able to view in talend but after that its not executing.
Even executed manualy and trigger time and date. but still some problem.

Status: Ready to deploy
Error status: Sending error
Label: Business_Extraction
Time left before next triggering:
Next triggering on:
Triggers status:
Last script generation: 2011-05-31 11:22:31
SVN revision: 315
Last deployment:
Last run:
Last ended run:
Project: Sandbox_admin1_project
Branch: trunk
Job: BUSINESS_UNITS_Data_Extraction
Version: 0.1
Regenerate job on change: true
Context: Default
Apply context to children: true
Execution server: SandboxProjectServer
Virtual server:
Id: 195
Statistics state: enabled
On unavailable JobServer: Reset task
Last occurred error:


org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
Caused by: java.net.SocketException: socket closed
org.talend.remote.jobserver.client.FileSenderClient.getThrowedFileSendingException(Unknown Source)
org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
Caused by: socket closed
java.net.SocketInputStream.socketRead0(Native Method)
java.net.SocketInputStream.read(SocketInputStream.java:129)
sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
java.io.InputStreamReader.read(InputStreamReader.java:167)
java.io.BufferedReader.fill(BufferedReader.java:136)
java.io.BufferedReader.readLine(BufferedReader.java:299)
java.io.BufferedReader.readLine(BufferedReader.java:362)
org.talend.remote.jobserver.client.FileSenderClient.intoListeningLoop(Unknown Source)
org.talend.remote.commons.AbstractClientServerSocket.runListeningMessageStrategy(Unknown Source)
org.talend.remote.commons.AbstractClientServerSocket$1.run(Unknown Source)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:662)

Thanks & Regards
Chandu

[shong]

Hi
From your screenshots, I see it is failed to deploy the job to jobserver. You must deploy the job to jobserver successfully before you run manually it or add trigger on it. However, the status of jobserver shows fine, all the ports display green.
Is the job server installed on the same machine as TAC?
Do you test to add another job server?
Best regards
Shong

[chandu282003]

ya job server is in TAC machine , but job is not executing. added trigger also in job conductor . find the details in screen shot.
it is problem in ready to deploy , once i click on deploy button thats all nothing is happening. please find below jboss server console errors.
i think its not Deploying the job.
pls help shong.

11:55:18,859 INFO ... 4 more
11:55:18,859 INFO Caused by: org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
11:55:18,859 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
11:55:18,859 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
11:55:18,859 INFO Caused by: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
11:55:18,860 INFO at org.talend.remote.jobserver.client.FileSenderClient.getThrowedFileSendingException(Unknown Source)
11:55:18,860 INFO ... 2 more
11:55:18,860 INFO Caused by: java.net.SocketException: socket closed
11:55:18,860 INFO at java.net.SocketInputStream.socketRead0(Native Method)
11:55:18,860 INFO at java.net.SocketInputStream.read(SocketInputStream.java:129)
11:55:18,860 INFO at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
11:55:18,860 INFO at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
11:55:18,861 INFO at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
11:55:18,861 INFO at java.io.InputStreamReader.read(InputStreamReader.java:167)
11:55:18,861 INFO at java.io.BufferedReader.fill(BufferedReader.java:136)
11:55:18,861 INFO at java.io.BufferedReader.readLine(BufferedReader.java:299)
11:55:18,861 INFO at java.io.BufferedReader.readLine(BufferedReader.java:362)
11:55:18,861 INFO at org.talend.remote.jobserver.client.FileSenderClient.intoListeningLoop(Unknown Source)
11:55:18,861 INFO at org.talend.remote.commons.AbstractClientServerSocket.runListeningMessageStrategy(Unknown Source)
11:55:18,861 INFO at org.talend.remote.commons.AbstractClientServerSocket$1.run(Unknown Source)
11:55:18,862 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
11:55:18,862 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
11:55:18,862 INFO at java.lang.Thread.run(Thread.java:662)

12:06:14,267 INFO 2011-06-01 12:06:14 INFO RemoteJobExecution - ###### Task STARTED - ExecutionTask
12:06:17,049 INFO 2011-06-01 12:06:17 INFO ProcessItemLoader - LOADING data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs...
12:06:17,087 INFO 2011-06-01 12:06:17 INFO ProcessItemLoader - Data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs LOADED in 0 seconds.
12:06:34,828 INFO 2011-06-01 12:06:34 INFO ProcessItemLoader - LOADING data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs...
12:06:34,839 INFO 2011-06-01 12:06:34 INFO ProcessItemLoader - Data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs LOADED in 0 seconds.
12:06:50,692 INFO 2011-06-01 12:06:50 WARN FileSenderClient - java.net.SocketException: socket closed

[shong]

Hi
Yes, the problem is failed to deploy the job to jobserver, don't add the trigger before you finish the deploy! Can you check whether the job server is running?
Best regards
Shong

[chandu282003]

deleted all the existing triggers , than checked job server it given below warning, after that i have started deploy the jobs , still same issue.
It started with Generating... than status changed to ready_to_deploy only. i clicked again on deploy , than status came to generating , ....

WARN AbstractDataCleaner - pathDir is not a directory: D:\org.talend.remote.jobserver_4.1.2_r53616\.\TalendJobServersFiles\repository
deployement tomcat issue.

17:55:33,429 INFO 2011-06-01 17:55:33 INFO TriggerHandler - Quartz Trigger '2' can't be found to be removed, it may have been already consumed.
17:55:48,814 INFO 2011-06-01 17:55:48 INFO TriggerHandler - Quartz Trigger '1' can't be found to be removed, it may have been already consumed.
17:56:12,713 INFO 2011-06-01 17:56:12 INFO ProcessItemLoader - LOADING data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs...
17:56:12,722 INFO 2011-06-01 17:56:12 INFO ProcessItemLoader - Data model of job 'BUSINESS_UNITS_Data_Extraction' and all its children jobs LOADED in 0 seconds.
17:56:26,128 INFO 2011-06-01 17:56:26 INFO PropertiesLoader - Creating bundle 'org.talend.gwtadministrator.client.common.i18n.Messages'
18:21:03,438 INFO 2011-06-01 18:21:03 INFO SchedulerDataCleaner - TempDataCleaner, 1 archive jobs cleaned
18:32:13,697 INFO 2011-06-01 18:32:13 WARN FileSenderClient - java.net.SocketException: socket closed
18:32:29,724 INFO 2011-06-01 18:32:29 WARN VirtualServerJobDeployer - Error when 'Sending... on JobServer 'SandboxProjectServer' (10.1.5.59:8001)
18:32:29,724 INFO org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,724 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
18:32:29,725 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
18:32:29,725 INFO Caused by: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,725 INFO at org.talend.remote.jobserver.client.FileSenderClient.getThrowedFileSendingException(Unknown Source)
18:32:29,725 INFO ... 2 more
18:32:29,725 INFO Caused by: java.net.SocketException: socket closed
18:32:29,725 INFO at java.net.SocketInputStream.socketRead0(Native Method)
18:32:29,725 INFO at java.net.SocketInputStream.read(SocketInputStream.java:129)
18:32:29,725 INFO at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
18:32:29,725 INFO at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
18:32:29,726 INFO at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
18:32:29,726 INFO at java.io.InputStreamReader.read(InputStreamReader.java:167)
18:32:29,726 INFO at java.io.BufferedReader.fill(BufferedReader.java:136)
18:32:29,726 INFO at java.io.BufferedReader.readLine(BufferedReader.java:299)
18:32:29,726 INFO at java.io.BufferedReader.readLine(BufferedReader.java:362)
18:32:29,726 INFO at org.talend.remote.jobserver.client.FileSenderClient.intoListeningLoop(Unknown Source)
18:32:29,726 INFO at org.talend.remote.commons.AbstractClientServerSocket.runListeningMessageStrategy(Unknown Source)
18:32:29,726 INFO at org.talend.remote.commons.AbstractClientServerSocket$1.run(Unknown Source)
18:32:29,726 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
18:32:29,726 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
18:32:29,726 INFO at java.lang.Thread.run(Thread.java:662)
18:32:29,727 INFO 2011-06-01 18:32:29 ERROR ExecutionTaskHandler - org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,727 INFO org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,727 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
18:32:29,727 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
18:32:29,727 INFO Caused by: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,727 INFO at org.talend.remote.jobserver.client.FileSenderClient.getThrowedFileSendingException(Unknown Source)
18:32:29,727 INFO ... 2 more
18:32:29,727 INFO Caused by: java.net.SocketException: socket closed
18:32:29,727 INFO at java.net.SocketInputStream.socketRead0(Native Method)
18:32:29,728 INFO at java.net.SocketInputStream.read(SocketInputStream.java:129)
18:32:29,728 INFO at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
18:32:29,728 INFO at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
18:32:29,728 INFO at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
18:32:29,728 INFO at java.io.InputStreamReader.read(InputStreamReader.java:167)
18:32:29,728 INFO at java.io.BufferedReader.fill(BufferedReader.java:136)
18:32:29,728 INFO at java.io.BufferedReader.readLine(BufferedReader.java:299)
18:32:29,728 INFO at java.io.BufferedReader.readLine(BufferedReader.java:362)
18:32:29,728 INFO at org.talend.remote.jobserver.client.FileSenderClient.intoListeningLoop(Unknown Source)
18:32:29,728 INFO at org.talend.remote.commons.AbstractClientServerSocket.runListeningMessageStrategy(Unknown Source)
18:32:29,728 INFO at org.talend.remote.commons.AbstractClientServerSocket$1.run(Unknown Source)
18:32:29,728 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
18:32:29,729 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
18:32:29,729 INFO at java.lang.Thread.run(Thread.java:662)
18:32:29,862 INFO 2011-06-01 18:32:29 ERROR ExecutionTaskHandler - org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientServerException
18:32:29,862 INFO org.talend.administrator.common.exception.ProcessedException: org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientSe
18:32:29,863 INFO at org.talend.administrator.scheduler.business.ExecutionTaskHandler.deployJobUnit(ExecutionTaskHandler.java:578)
18:32:29,863 INFO at org.talend.administrator.scheduler.business.ExecutionTaskHandler.access$100(ExecutionTaskHandler.java:138)
18:32:29,863 INFO at org.talend.administrator.scheduler.business.ExecutionTaskHandler$2.run(ExecutionTaskHandler.java:426)
18:32:29,863 INFO Caused by: org.talend.designer.runprocess.ProcessorException: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket clo
18:32:29,863 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.send(VirtualServerJobDeployerCached.java:395)
18:32:29,863 INFO at org.talend.administrator.scheduler.business.job.deploy.VirtualServerJobDeployerCached$SenderThread.run(VirtualServerJobDeployerCached.java:225)
18:32:29,863 INFO Caused by: org.talend.remote.commons.exception.ClientServerException: java.net.SocketException: socket closed
18:32:29,863 INFO at org.talend.remote.jobserver.client.FileSenderClient.getThrowedFileSendingException(Unknown Source)
18:32:29,863 INFO ... 2 more
18:32:29,863 INFO Caused by: java.net.SocketException: socket closed
18:32:29,864 INFO at java.net.SocketInputStream.socketRead0(Native Method)
18:32:29,864 INFO at java.net.SocketInputStream.read(SocketInputStream.java:129)
18:32:29,864 INFO at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
18:32:29,864 INFO at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
18:32:29,864 INFO at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
18:32:29,864 INFO at java.io.InputStreamReader.read(InputStreamReader.java:167)
18:32:29,864 INFO at java.io.BufferedReader.fill(BufferedReader.java:136)
18:32:29,864 INFO at java.io.BufferedReader.readLine(BufferedReader.java:299)
18:32:29,864 INFO at java.io.BufferedReader.readLine(BufferedReader.java:362)
18:32:29,864 INFO at org.talend.remote.jobserver.client.FileSenderClient.intoListeningLoop(Unknown Source)
18:32:29,864 INFO at org.talend.remote.commons.AbstractClientServerSocket.runListeningMessageStrategy(Unknown Source)
18:32:29,865 INFO at org.talend.remote.commons.AbstractClientServerSocket$1.run(Unknown Source)
18:32:29,865 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
18:32:29,865 INFO at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
18:32:29,865 INFO at java.lang.Thread.run(Thread.java:662)

[shong]

Hi Chandu
You are a paying cusomter, please open a support ticket so that we can assist you further, schedule a webex if needed and investigate the problem on site.
Best regards
Shong

[etg]

Hi we are using TIS but, we unable to schedule the jobs in talend. we want to do itself in talend scheduler.
Whenever we give all the parameter as job name,date,time and save it as .txt format, but the job does not start. would any body please help if any thing we are missing.

[shong · Accepted solution]

Hi we are using TIS but, we unable to schedule the jobs in talend. we want to do itself in talend scheduler.
Whenever we give all the parameter as job name,date,time and save it as .txt format, but the job does not start. would any body please help if any thing we are missing.

The scheduler inside studio is not available. To schedule the jobs, you should open the Talend Administrator Center(TAC) and schedule it on Job conductor.
Best regards
Shong

[etg]

Thanks shong