counter++;
        }

        @Override
        public void close() {
            if (counter > 1) {
                counter--;
            } else {
                contextLocal.remove();
                if (context != null) {
                    try {
                        context.close();
                    } catch (final NamingException e) {
                        // ignored

            } catch (final Exception e) {
                logger.warn("Failed to flush indices.", e);
            }
        }
        try {
            client.close();
        } catch (final OpenSearchException e) {
            logger.warn("Failed to close Client: {}", client, e);
        }
    }

    public long updateByQuery(final String index, final Function<SearchRequestBuilder, SearchRequestBuilder> option,