[FLINK-3882] Errors in sample Java code for the Elasticsearch 2.x sink

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 1.1.0
• Component/s: Connectors / Common, Documentation
• Assignee: Mark Reddy
• Reporter: Mark Reddy
• Created: 08/May/16 20:31
• Updated: 13/Apr/21 20:39
• Resolved: 10/May/16 20:39

Description

The sample Java code for the Elasticsearch 2.x sink doc[1] has numerous errors in it, which seems to be resulting from porting the Scala example to Java.

e.g.

  public IndexRequest createIndexRequest(String element): IndexRequest = {
    Map<String,String> json = new HashMap<>()
    json.put("data", element)

[1] https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html