Hello, may I know when this program will be upgraded for elasticsearch 7.x and Flink 1.10.0

[liningwonder]

it looks like

public void configure(Configuration configuration) {
        HttpHost[] httpHosts = new HttpHost[hosts.size()];
        for (int i = 0; i < hosts.size(); i++) {
            httpHosts[i] = new HttpHost(hosts.get(i), port, schema);
        }
        client = new RestHighLevelClient(RestClient.builder(httpHosts));

        //Listener
        BulkProcessor.Listener listener = new BulkProcessor.Listener(){
            @Override
            public void beforeBulk(long l, BulkRequest bulkRequest) {

            }

            @Override
            public void afterBulk(long l, BulkRequest bulkRequest, BulkResponse bulkResponse) {
                if (bulkResponse.hasFailures()) {
                    for (BulkItemResponse itemResp : bulkResponse.getItems()) {
                        if (itemResp.isFailed()) {
                            LOG.error("Failed to index document in Elasticsearch: " + itemResp.getFailureMessage());
                            failureThrowable.compareAndSet(null, new RuntimeException(itemResp.getFailureMessage()));
                        }
                    }
                    hasFailure.set(true);
                }
            }

            @Override
            public void afterBulk(long l, BulkRequest bulkRequest, Throwable throwable) {
                LOG.error(throwable.getMessage());
                failureThrowable.compareAndSet(null, throwable);
                hasFailure.set(true);
            }
        };
        //Builder
        BulkProcessor.Builder bulkProcessorBuilder =
                BulkProcessor.builder((request, bulkListener) -> client.bulkAsync(request, RequestOptions.DEFAULT, bulkListener), listener);
        //Config
        if (userConfig.containsKey(Constant.CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS)) {
            bulkProcessorBuilder.setBulkActions(stringToInt(userConfig.get(Constant.CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS)));
        }
        if (userConfig.containsKey(Constant.CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB)) {
            bulkProcessorBuilder.setBulkSize(new ByteSizeValue(stringToInt(
                    Constant.CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB), ByteSizeUnit.MB));
        }
        if (userConfig.containsKey(Constant.CONFIG_KEY_BULK_FLUSH_INTERVAL_MS)) {
            bulkProcessorBuilder.setFlushInterval(TimeValue.timeValueMillis(stringToInt(Constant.CONFIG_KEY_BULK_FLUSH_INTERVAL_MS)));
        }
        //BulkProcessor
        bulkProcessor = bulkProcessorBuilder.build();
        requestIndexer = new BulkProcessorIndexer(bulkProcessor);
    }