日期: 2021年5月13日

执行Java任务

type 类型为 javaprocess的job，可以运行一个自定义Java类的main方法，可用的配置如下：

• Xms：最小堆
• Xmx：最大堆
• classpath：类路径
• java.class：要运行的 Java 对象，其中必须包含 Main 方法
• main.args： main 方法的参数

案例：

• 1、新建一个 azkaban 的 maven 工程
• 2、创建包名： com.kkb.azkaban
• 3、包中创建 JavaProcessTest 类

package com.kkb.azkaban;

public class JavaProcessTest {
  public static void main(String[] args) {
      System.out.println("This is " + args[0] + " javaprocess job type test!");
  }
}

代码打包，生成jar包

编写flow文件javaProcessTest.flow，内容如下

nodes:
- name: testJavaProcess
  type: javaprocess
  config:
    Xms: 96M
    Xmx: 200M
    java.class: com.kkb.azkaban.JavaProcessTest
    main.args: MyAzkaban

将jar包、flow文件、project文件压缩生成zip文件

web ui创建工程、上传zip、执行flow

Views: 6