private void checkErrors()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduWriter.java [152:158]

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

    private void checkErrors(OperationResponse response) throws IOException {
        if (response != null && response.hasRowError()) {
            failureHandler.onFailure(Collections.singletonList(response.getRowError()));
        } else {
            checkAsyncErrors();
        }
    }