Loading src/main/java/io/confluent/connect/elasticsearch/Mapping.java +1 −1 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ public class Mapping { PutMapping putMapping = new PutMapping.Builder(index, type, obj.toString()).build(); JestResult result = client.execute(putMapping); if (!result.isSucceeded()) { throw new ConnectException("Cannot create mapping:" + obj.toString()); throw new ConnectException("Cannot create mapping " + obj + " -- " + result.getErrorMessage()); } } Loading Loading
src/main/java/io/confluent/connect/elasticsearch/Mapping.java +1 −1 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ public class Mapping { PutMapping putMapping = new PutMapping.Builder(index, type, obj.toString()).build(); JestResult result = client.execute(putMapping); if (!result.isSucceeded()) { throw new ConnectException("Cannot create mapping:" + obj.toString()); throw new ConnectException("Cannot create mapping " + obj + " -- " + result.getErrorMessage()); } } Loading