public WorkflowResult restartProcess(String groupId, String operator) {
        LOGGER.info("begin to restart process for groupId={} by operator={}", groupId, operator);

        groupService.updateStatus(groupId, GroupStatus.CONFIG_ONLINE_ING.getCode(), operator);
        InlongGroupInfo groupInfo = groupService.get(groupId);
        GroupResourceProcessForm form = genGroupResourceProcessForm(groupInfo, GroupOperateType.RESTART);
        WorkflowResult result = workflowService.start(ProcessName.RESTART_GROUP_PROCESS, operator, form);
        List<TaskResponse> tasks = result.getNewTasks();
        if (TaskStatus.FAILED == tasks.get(tasks.size() - 1).getStatus()) {
            throw new BusinessException(ErrorCodeEnum.WORKFLOW_RESTART_RECORD_FAILED,
                    String.format("failed to restart inlong group for groupId=%s", groupId));
        }

        LOGGER.info("success to restart process for groupId={} by operator={}", groupId, operator);
        return result;
    }
Restart InlongGroup which is started up successfully, starting from the last persist snapshot.

@param groupId inlong group id
@param operator name of operator
@return workflow result
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupProcessService.java