[FLINK-13519] Elasticsearch Connector sample code for Scala on version 6.x will not work

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.2, 1.8.0, 1.8.1
• Fix Version/s: 1.10.0
• Component/s: Connectors / ElasticSearch, Documentation
• Labels: pull-request-available
• Assignee: Alberto Romero
• Reporter: Alberto Romero
• Created: 31/Jul/19 21:50
• Updated: 23/Oct/19 10:04
• Resolved: 23/Oct/19 10:04

Description

The Scala example in the documentation for the Elasticsearch Connector, version 6.x, will not work. The class ElasticsearchSinkFunction[String] requires a RuntimeContext and a RequestIndexer, which the example omits.

Also, type needs to be in inverse quotes as it's a Scala keyword.

It should look like the following:

def process(element: String, ctx: RuntimeContext, indexer: RequestIndexer) { 
   val json = new java.util.HashMap[String, String] 
   json.put("data", element) 

   val rqst: IndexRequest = Requests.indexRequest
      .index("testarindex")
      .`type`("_doc")
      .source(json) 

   indexer.add(rqst) 
}

 

Issue Links

• links to: GitHub Pull Request #9309