5.1.2 client做成单例的一直不关闭会出问题吗

BulkProcessor bulkProcessor = BulkProcessor.builder(client, new BulkProcessor.Listener() {

	@Override

	public void beforeBulk(long executionId, BulkRequest request) {

	}

	@Override

	public void afterBulk(long executionId, BulkRequest request, BulkResponse response) {

	}

	@Override

	public void afterBulk(long executionId, BulkRequest request, Throwable failure) {

	}

}).setBulkActions(2000)

    .setBulkSize(new ByteSizeValue(50, ByteSizeUnit.MB))

	.setFlushInterval(TimeValue.timeValueSeconds(60)).build();

if(bulkProcessor!=null){

	try {

		while(!bulkProcessor.awaitClose(5, TimeUnit.SECONDS)){



		}

	} catch (InterruptedException e) {

		e.printStackTrace();

	}

}



if(client!=null){

	client.close();

}