private void loadData(Map<String, List<Map<String, Object>>> tmpCache) throws IOException {
        Elasticsearch7SideTableInfo tableInfo = (Elasticsearch7SideTableInfo) sideInfo.getSideTableInfo();

        try {
            for (int i = 0; i < CONN_RETRY_NUM; i++) {
                try {
                    rhlClient = Es7Util.getClient(tableInfo.getAddress(), tableInfo.isAuthMesh(), tableInfo.getUserName(), tableInfo.getPassword());
                    break;
                } catch (Exception e) {
                    if (i == CONN_RETRY_NUM - 1) {
                        throw new RuntimeException("", e);
                    }

                    try {
                        String connInfo = "url: " + tableInfo.getAddress() + "; userName: " + tableInfo.getUserName() + ", pwd:" + tableInfo.getPassword();
                        LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + connInfo);
                        Thread.sleep(LOAD_DATA_ERROR_SLEEP_TIME);
                    } catch (InterruptedException e1) {
                        LOG.error("", e1);
                    }
                }

            }
            SearchSourceBuilder searchSourceBuilder = initConfiguration(boolQueryBuilder);
            searchData(searchSourceBuilder, tmpCache);

        } catch (Exception e) {
            LOG.error("", e);
            throw new RuntimeException(e);
        } finally {

            if (rhlClient != null) {
                rhlClient.close();
            }
        }
    }
@description:
@program: flink.sql
@author: lany
@create: 2021/01/11 14:53
elasticsearch7/elasticsearch7-side/elasticsearch7-all-side/src/main/java/com/dtstack/flink/sql/side/elasticsearch7/Elasticsearch7AllReqRow.java