bug fix when jvm shudown the bulkProcessor will close

sishu@dtstack.com · sishu@dtstack.com · commit 3c8896b4d5ce · 2016-11-30T11:48:10.000+08:00
diff --git a/elasticsearch/src/main/java/com/dtstack/logstash/outputs/Elasticsearch.java b/elasticsearch/src/main/java/com/dtstack/logstash/outputs/Elasticsearch.java
@@ -253,7 +253,6 @@ public void sendFailedMsg(Object msg){
     @Override
     public void release(){
     	if(bulkProcessor!=null)bulkProcessor.close();
-    	if(esclient!=null)esclient.close();	
     }
     
     public void checkNeedWait(){
diff --git a/elasticsearch5/src/main/java/com/dtstack/logstash/outputs/Elasticsearch5.java b/elasticsearch5/src/main/java/com/dtstack/logstash/outputs/Elasticsearch5.java
@@ -256,7 +256,6 @@ public void sendFailedMsg(Object msg){
     @Override
     public void release(){
     	if(bulkProcessor!=null)bulkProcessor.close();
-    	if(esclient!=null)esclient.close();	
     }
     
     public void checkNeedWait(){

Original file line number	Diff line number	Diff line change
`@@ -253,7 +253,6 @@ public void sendFailedMsg(Object msg){`
`253`	`253`	`@Override`
`254`	`254`	`public void release(){`
`255`	`255`	`if(bulkProcessor!=null)bulkProcessor.close();`
`256`		`- if(esclient!=null)esclient.close();`
`257`	`256`	`}`
`258`	`257`
`259`	`258`	`public void checkNeedWait(){`
Original file line number	Diff line number	Diff line change
`@@ -256,7 +256,6 @@ public void sendFailedMsg(Object msg){`
`256`	`256`	`@Override`
`257`	`257`	`public void release(){`
`258`	`258`	`if(bulkProcessor!=null)bulkProcessor.close();`
`259`		`- if(esclient!=null)esclient.close();`
`260`	`259`	`}`
`261`	`260`
`262`	`261`	`public void checkNeedWait(){`