public String restartProcessAsync(String groupId, String operator) {
        LOGGER.info("begin to restart process asynchronously 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);
        UserInfo userInfo = LoginUserUtils.getLoginUser();
        EXECUTOR_SERVICE.execute(
                () -> workflowService.startAsync(ProcessName.RESTART_GROUP_PROCESS, userInfo, form));

        LOGGER.info("success to restart process asynchronously for groupId={} by operator={}", groupId, operator);
        return groupId;
    }
Restart InlongGroup in an asynchronous way, 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