private void validateConfiguration()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java [122:127]

• 6 lines of code
• 3 McCabe index (conditional complexity)

    private void validateConfiguration() {
        if (boundedness == Boundedness.CONTINUOUS_UNBOUNDED && discoveryInterval == null) {
            throw new IllegalArgumentException(
                    "discoveryInterval must be set for CONTINUOUS_UNBOUNDED mode.");
        }
    }