diff --git a/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisClient.java b/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisClient.java index aadf0010..64cc5163 100644 --- a/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisClient.java +++ b/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisClient.java @@ -4275,11 +4275,6 @@ public Long ehset(final String key, final String field, final String value, fina final Response hResponse = pipeline.hset(ehashDataKey(key), field, value); pipeline.sync(); - // If metadata operation failed, remove the data and throw exception - if (zResponse.get() != 1) { - d_hdel(ehashDataKey(key), field); - throw new DynoException("Failed to set field:" + field + "; Metadata operation failed:" + zResponse.get()); - } return hResponse.get(); } @@ -4462,11 +4457,6 @@ public String ehmset(final String key, final Map> has final Response hResponse = pipeline.hmset(ehashDataKey(key), fields); pipeline.sync(); - // If metadata operation failed, remove the data and throw exception - if (zResponse.get() != hash.size()) { - d_hdel(ehashDataKey(key), fields.keySet().toArray(new String[0])); - throw new DynoException("Failed to set fields; Metadata operation failed:" + zResponse.get()); - } return hResponse.get(); }