public InlongClusterNodeOperator getInstance(String type) {
        return clusterNodeOperatorList.stream()
                .filter(inst -> inst.accept(type))
                .findFirst()
                .orElseGet(() -> clusterNodeOperatorList.stream()
                        .filter(inst -> inst.accept(DEFAULT))
                        .findFirst()
                        .orElseThrow(
                                () -> new BusinessException(ErrorCodeEnum.CLUSTER_TYPE_NOT_SUPPORTED,
                                        String.format(ErrorCodeEnum.CLUSTER_TYPE_NOT_SUPPORTED.getMessage(), type))));
    }
Get a cluster node operator instance via the given type
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/InlongClusterNodeOperatorFactory.java