@Override
    public void close() throws Exception {
        super.close();
        if (rhlClient != null) {
            try {
                rhlClient.close();
            } catch (IOException ex) {
                LOG.warn("Failed to shutdown tmpRhlClient.", ex);
            }
        }
    }
@description:
@program: flink.sql
@author: lany
@create: 2021/01/11 11:21
elasticsearch7/elasticsearch7-side/elasticsearch7-async-side/src/main/java/com/dtstack/flink/sql/side/elasticsearch7/Elasticsearch7AsyncReqRow.java