我们知道，在azkaban内部有好几种调度程序，那么一个java程序怎么被执行的呢？

================================================================

其实更完整的是

下面我们来探索JavaProcessJob类型job的执行过程！

jdb azkaban.execapp.AzkabanExecutorServer-conf  /root/azkb/azkaban_3.0.0_debug/conf

stop in azkaban.jobExecutor.JavaProcessJob.HelloWorld

run

=========================================================================================================

privatevoidloadDefaultTypes(JobTypePluginSetplugins)throwsJobTypeManagerException {

logger.info("Loading plugin default job types");

plugins.addPluginClass("command", ProcessJob.class);

plugins.addPluginClass("javaprocess",JavaProcessJob.class);

plugins.addPluginClass("noop", NoopJob.class);

plugins.addPluginClass("python", PythonJob.class);

plugins.addPluginClass("ruby", RubyJob.class);

plugins.addPluginClass("script", ScriptJob.class);

}

=========================================================================================================

关于classPath的路径

protectedList getClassPaths() {

//

ListclassPaths= getJobProps().getStringList(CLASSPATH,null,",");

ArrayListclasspathList=newArrayList();

// Adding global properties used system wide.

//

if(getJobProps().containsKey(GLOBAL_CLASSPATH)) {

ListglobalClasspath= getJobProps().getStringList(GLOBAL_CLASSPATH);

for(Stringglobal:globalClasspath) {

getLog().info("Adding to global classpath:"+global);

classpathList.add(global);

}

}

//

if(classPaths==null) {

Filepath=newFile(getPath());

// File parent = path.getParentFile();

getLog().info("No classpath specified. Trying to load classes from "+path);

if(path!=null) {

for(Filefile:path.listFiles()) {

if(file.getName().endsWith(".jar")) {

// log.info("Adding to classpath:" + file.getName());

classpathList.add(file.getName());

}

}

}

}else{

classpathList.addAll(classPaths);

}

returnclasspathList;

}

一个可用的是

commands = "

[

java -Dazkaban.flowid=javaprocess -Dazkaban.execid=193 -Dazkaban.jobid=javaprocess -Xms64M -Xmx256M -cp javaProcessTest.jar javaProcessTest.test

]"