update elasticsearch 5.1.1

Author: [email protected]

elasticsearch5/pom.xml

@@ -58,7 +58,7 @@
 		<dependency>
 			<groupId>org.elasticsearch.client</groupId>
 			<artifactId>transport</artifactId>
-			<version>5.0.1</version>
+			<version>5.1.1</version>
 		</dependency>
 
 		<dependency>

elasticsearch5/src/main/java/com/dtstack/logstash/outputs/Elasticsearch5.java

@@ -148,7 +148,7 @@ private void initESClient() throws NumberFormatException,
                     public void afterBulk(long arg0, BulkRequest arg1,
                                           BulkResponse arg2) {
 
-                        List<ActionRequest<?>> requests = arg1.requests();
+                        List<ActionRequest> requests = arg1.requests();
                         int toberetry = 0;
                         int totalFailed = 0;
                         for (BulkItemResponse item : arg2.getItems()) {
@@ -199,7 +199,7 @@ public void afterBulk(long arg0, BulkRequest arg1,
                                           Throwable arg2) {
                         logger.error("bulk got exception:", arg2);
 
-                        for(ActionRequest<?> request : arg1.requests()){
+                        for(ActionRequest request : arg1.requests()){
                         	addFailedMsg(request);
                         }