[FLINK-16280] Fix sample code errors in the documentation about elasticsearch connector

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.9.3, 1.10.1, 1.11.0
• Component/s: Connectors / ElasticSearch, Documentation
• Labels: pull-request-available
• Assignee: Jiaqi Li
• Reporter: Jiaqi Li
• Created: 25/Feb/20 15:13
• Updated: 18/Apr/20 00:51
• Resolved: 04/Mar/20 15:11

Description

When I refer to the document for coding, I find that there is an error demonstration in scala code in the Elasticsearch connector section of the Flink document.

esSinkBuilder.setRestClientFactory(
  restClientBuilder -> {
    restClientBuilder.setDefaultHeaders(...)
    restClientBuilder.setMaxRetryTimeoutMillis(...)
    restClientBuilder.setPathPrefix(...)
    restClientBuilder.setHttpClientConfigCallback(...)
  }
)

After modification.

esSinkBuilder.setRestClientFactory(new RestClientFactory {
  override def configureRestClientBuilder(restClientBuilder: RestClientBuilder): Unit = {
       restClientBuilder.setDefaultHeaders(...)
       restClientBuilder.setMaxRetryTimeoutMillis(...)
       restClientBuilder.setPathPrefix(...)
       restClientBuilder.setHttpClientConfigCallback(...)
  }
})

Issue Links

• links to: GitHub Pull Request #11216