oozie协调器操作重新运行

63lcw9qa  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(437)

我试图重新运行失败的协管员使用下面的命令,但每次都是重新启动一些随机协管员行动,而不是最旧的协管员行动第一。
oozie作业-重新运行{coordinator id}-操作6374-6441
先重新运行6404。我们怎样才能让它从6374开始重新运行呢?

6g8kf2rb

6g8kf2rb1#

我想现在看这段代码是不可能做到的: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);
            }

编辑:这里是apachejiraoozie-2766以及补丁。谢谢。

相关问题