[jira] [Created] (FLINK-16280) Fix sample code errors in the documentation about elasticsearch connector.

["Jiaqi Li (Jira)" <ji...@apache.org>]

Jiaqi Li created FLINK-16280:
--------------------------------

             Summary: Fix sample code errors in the documentation about elasticsearch connector.
                 Key: FLINK-16280
                 URL: https://issues.apache.org/jira/browse/FLINK-16280
             Project: Flink
          Issue Type: Improvement
            Reporter: Jiaqi Li


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.


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

After modification.


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






--
This message was sent by Atlassian Jira
(v8.3.4#803005)