diff --git ql/src/java/org/apache/hadoop/hive/ql/hooks/WriteEntity.java ql/src/java/org/apache/hadoop/hive/ql/hooks/WriteEntity.java index 2194a6d..5004bd4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/hooks/WriteEntity.java +++ ql/src/java/org/apache/hadoop/hive/ql/hooks/WriteEntity.java @@ -168,7 +168,7 @@ public boolean equals(Object o) { if (o instanceof WriteEntity) { WriteEntity ore = (WriteEntity) o; - return (toString().equalsIgnoreCase(ore.toString())); + return (toString().equalsIgnoreCase(ore.toString())) && this.writeType == ore.writeType; } else { return false; }