[FLINK-11346] Could not enable basic authentication with elastic search connector

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Not A Problem
• Component/s: Connectors / ElasticSearch
• Assignee: Unassigned
• Reporter: kannan
• Created: 16/Jan/19 14:00
• Updated: 18/Jun/20 09:37
• Resolved: 16/Jan/19 14:23

Description

Hello Team, 

I am trying to add elasticsearch as sink and my current elasticsearch has enabled SSL and Basic authentication. 

I could not connect to elasticsearch with basic authentication. 

===========

code:

val credentialsProvider = new BasicCredentialsProvider
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("user", "password"))

esSinkBuilder.setRestClientFactory(
restClientBuilder -> {
restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback()

{ override def customizeHttpClient(httpClientBuilder: HttpAsyncClientBuilder) = httpClientBuilder .setDefaultCredentialsProvider(credentialsProvider) }

)
}
)

===========

 

Error Log:

Error:(70, 7) not found: value restClientBuilder
restClientBuilder -> {

 

Application version used 

scala - 2.11

flink - 1.7

elasticsearch - 6.5

elasticsearch connector version - 2.11

Issue Links

• is duplicated by: FLINK-16788 Support username and password options for Elasticsearch SQL connector