Действие Java в рабочем процессе Apache Oozie ⇐ Apache

[Anonymous]

Я пытаюсь настроить рабочий процесс Apache Oozie для выполнения различных действий в зависимости от дня недели. Прочитав https://stackoverflow.com/questions/714 ... f-the-week, я пытаюсь разработать решение самостоятельно.
Я начал с компиляции этого простого исходного кода Java:

Код: Выделить всё

import java.time.DayOfWeek;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.Scanner;

public class DatetimeProcessor {
public static void main(String[] args) {
String inputDate = args.length > 0 ? args[0] : "";
String day = "";
try {
day = getDayOfWeek(inputDate);
} catch (Exception e) {
System.out.println("Invalid date format. Please enter a valid date in the format 'yyyy-MM-dd'T'HH:mm'Z'.");
}
System.out.println("dayOfWeek=" + day);
}

public static String getDayOfWeek(String date) {
LocalDateTime dateTime = LocalDateTime.parse(date, DateTimeFormatter.ISO_DATE_TIME);
DayOfWeek dayOfWeek = dateTime.atOffset(ZoneOffset.UTC).getDayOfWeek();
return dayOfWeek.toString().substring(0, 3);
}
}

После создания jar-файла я написал этому координатору Oozie:

Код: Выделить всё

/user/my.user.name


nominalTime
${coord:nominalTime()}

Однако, когда я запускаю следующий рабочий процесс:

Код: Выделить всё

nominalTime






${jobTracker}
${nameNode}
DatetimeProcessor
${nominalTime}
${wf:appPath()}/DatetimeProcessor.jar








my.user.name@domain.it
Mail Test

Workflow id: ${wf:id()}
Workflow usr: ${wf:user()}
Timestamp: ${timestamp()}
Coordinator nominalTime: ${nominalTime}
Coordinator Day of the Week: ${wf:actionData("process-date-action")["dayOfWeek"]}






Workflow failed, error message[${wf:errorMessage(wf:lastErrorNode())}]

Я не вижу никаких результатов в последнем электронном письме после «Дня недели координатора:». Я неправильно использовал выходной тег захвата?
Заранее спасибо.


Подробнее здесь: https://stackoverflow.com/questions/791 ... e-workflow