public void close()

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

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

    public void close() throws Exception {
        opensearchSinkFunction.close();
        if (bulkProcessor != null) {
            bulkProcessor.close();
            bulkProcessor = null;
        }

        if (client != null) {
            client.close();
            client = null;
        }

        // make sure any errors from callbacks are rethrown
        checkErrorAndRethrow();
    }