Mark Reddy created FLINK-3882: --------------------------------- Summary: Errors in sample Java code for the Elasticsearch 2.x sink Key: FLINK-3882 URL: https://issues.apache.org/jira/browse/FLINK-3882 Project: Flink Issue Type: Bug Components: Documentation, Streaming Connectors Affects Versions: 1.1.0 Reporter: Mark Reddy Priority: Trivial
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. {code} public IndexRequest createIndexRequest(String element): IndexRequest = { Map<String,String> json = new HashMap<>() json.put("data", element) {code} [1] https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html -- This message was sent by Atlassian JIRA (v6.3.4#6332)