private static Throwable extractFailureCauseFromBulkItemResponse()

in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java [607:614]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    private static Throwable extractFailureCauseFromBulkItemResponse(
            BulkItemResponse bulkItemResponse) {
        if (!bulkItemResponse.isFailed()) {
            return null;
        } else {
            return bulkItemResponse.getFailure().getCause();
        }
    }