CODEWITHSUNDEEP
pentahokettlepdi
Claudio
Claudio

Reputation: 10947

Kettle (Pentaho PDI): Couldn't find starting point in this job

I'm manually creating a Job using Kettle from Java, but I get the error message Couldn't find starting point in this job.

KettleEnvironment.init();
JobMeta jobMeta = new JobMeta();
JobEntrySpecial start = new JobEntrySpecial("START", true, false);
start.setStart(true);
JobEntryCopy startEntry = new JobEntryCopy(start);
jobMeta.addJobEntry(startEntry);                    

JobEntryTrans jet1 = new JobEntryTrans("first");
Trans trans1 = jet1.getTrans();
jet1.setFileName("file.ktr");
JobEntryCopy jc1 = new JobEntryCopy(jet1);
jobMeta.addJobEntry(jc1);

jobMeta.addJobHop(new JobHopMeta(startEntry, jc1));
Job job = new Job(null, jobMeta);
job.setInteractive(true);
job.start();

Upvotes: 0

Views: 1032

Answers (2)

Claudio
Claudio

Reputation: 10947

I've discovered that I was missing

job.setStartJobEntryCopy(startEntry);

Upvotes: 1

simar
simar

Reputation: 1822

Class org.pentaho.di.job.JobMeta class has method findJobEntry

U can use it to look for entry point called "START

This is how it is original source of kettle-pdi 

private JobMeta jobMeta;
....

// Where do we start?
jobEntryCopy startpoint;
....

if ( startJobEntryCopy == null ) {
        startpoint = jobMeta.findJobEntry( JobMeta.STRING_SPECIAL_START, 0, false );

// and then 
JobEntrySpecial jes = (JobEntrySpecial) startpoint.getEntry();

Upvotes: 0

Related Questions