hadoop - Oozie协调员操作重新运行

Question

我正在尝试使用以下命令重新运行失败的协调器，但是每次重新启动时，都会使用一些随机的协调器操作，而不是首先执行最旧的协调器操作。

oozie job -rerun {co-ordinator ID} -action 6374-6441

首先重新运行6404。我们如何才能使其从6374开始重新运行？

Answer 1

我想目前无法通过查看这段代码来实现:getActionsIds

    Set<String> actions = new HashSet<String>();
    String[] list = scope.split(",");
    for (String s : list) {
        s = s.trim();
        // An action range is specified with two actions separated by '-'
        if (s.contains("-")) {
            String[] range = s.split("-");
        ...............
            int start;
            int end;
            //Get the starting and ending action numbers
            try {
                start = Integer.parseInt(range[0].trim());
            } catch (NumberFormatException ne) {
                throw new CommandException(ErrorCode.E0302, "could not parse " + range[0].trim() + "into an integer", ne);
            }
            try {
                end = Integer.parseInt(range[1].trim());
            } catch (NumberFormatException ne) {
                throw new CommandException(ErrorCode.E0302, "could not parse " + range[1].trim() + "into an integer", ne);
            }
        ...............
            // Add the actionIds
            for (int i = start; i <= end; i++) {
                actions.add(jobId + "@" + i);
            }

编辑:这是 Apache Jira OOZIE-2766和补丁。谢谢。