private Optional validateResources()

in flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java [359:392]

• 29 lines of code
• 7 McCabe index (conditional complexity)

    private Optional<String> validateResources(String component, Resource resource) {
        if (resource == null) {
            return Optional.empty();
        }

        String memory = resource.getMemory();
        String storage = resource.getEphemeralStorage();
        StringBuilder builder = new StringBuilder();

        if (memory != null) {
            try {
                MemorySize.parse(memory);
            } catch (IllegalArgumentException iae) {
                builder.append(component + " resource memory parse error: " + iae.getMessage());
            }
        }

        if (storage != null) {
            try {
                Quantity quantity = Quantity.parse(storage);
                Quantity.getAmountInBytes(quantity);
            } catch (IllegalArgumentException iae) {
                builder.append(
                        component + " resource ephemeral storage parse error: " + iae.getMessage());
            }
        }

        String errorMessage = builder.toString();
        if (!StringUtils.isNullOrWhitespaceOnly(errorMessage)) {
            return Optional.of(errorMessage);
        }

        return Optional.empty();
    }