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)
