Loading src/main/java/io/confluent/connect/elasticsearch/BulkIndexingClient.java +1 −1 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ public class BulkIndexingClient implements BulkClient<IndexableRecord, Bulk> { } if (!versionConflicts.isEmpty()) { LOG.warn("Ignoring version conflicts for items: {}", versionConflicts); LOG.debug("Ignoring version conflicts for items: {}", versionConflicts); if (errors.isEmpty()) { // The only errors were version conflicts return BulkResponse.success(); Loading Loading
src/main/java/io/confluent/connect/elasticsearch/BulkIndexingClient.java +1 −1 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ public class BulkIndexingClient implements BulkClient<IndexableRecord, Bulk> { } if (!versionConflicts.isEmpty()) { LOG.warn("Ignoring version conflicts for items: {}", versionConflicts); LOG.debug("Ignoring version conflicts for items: {}", versionConflicts); if (errors.isEmpty()) { // The only errors were version conflicts return BulkResponse.success(); Loading