if (sb.length() > 0) {
return "failure in bulk execution:" + sb.toString();
}
return StringUtil.EMPTY;
}
<BUG>protected <T> BulkResponse doInsertAll(final List<T> list, final OpType opType) {
final BulkRequestBuilder bulkRequest = getClient().prepareBulk();
</BUG>
for (final T target : list) {
final String id = getId(getSessionId(target), getUrl(target));

if (sb.length() > 0) {
return "failure in bulk execution:" + sb.toString();
}
return StringUtil.EMPTY;
}
protected <T> BulkResponse doInsertAll(final List<T> list, final OpType opType) {
try {
return getClient().get(c -> {
final BulkRequestBuilder bulkRequest = c.prepareBulk();
for (final T target : list) {
final String id = getId(getSessionId(target), getUrl(target));
