Skip to content

类型:RDBMS(mysql/oracle)、HTTP

支持 ${name} 模式的宏替换:

xml
<round type="mysql"
       sql="update cpic_task_history set
       end_time = ${endtime}, final_status = ${status}, error_text = ${error} where id = ${uuid}"
       url="${jdbc.url}"
       driver="${jdbc.driverclass}"
       user="${jdbc.user}"
       password="${jdbc.password}" />

参数支持:

  1. 支持 property 中定义的变量;
  2. 支持 jvm system property 变量;
  3. 支持 Flow 运行期产生的变量;

Flow 运行期变量:

  • uuid 每个任务生成唯一的ID STRING
  • starttime 任务运行开始时间 Timestamp
  • endtime 任务运行结束时间 Timestamp
  • inputBytes 任务读入的数据量字节大小计数 Long
  • inputRecords 任务读入的数据量 Long
  • outputBytes 任务输出的数据量总字节大小计数 Long
  • outputRecords 任务输出的数据量 Long
  • jobCount Spark 分解的任务量 Long
  • taskCount Spark 分解的 Task 任务量 Long
  • status 任务的当前状态:RUNNING STRING
  • error 任务运行失败时的异常 STRING

Status 可选的值为:

  1. RUNNING;
  2. SUCCEEDED;
  3. FAILED;

Prepare round 和 after round 配合使用可用于记录 SparkSQL Flow 任务的运行日志:

round

和 Prepare Round 使用方法相同,见:【Prepare Round】