diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java index adce54c..d76f6b3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java @@ -7957,6 +7957,10 @@ private void setWriteIdForSurrogateKeys(LoadTableDesc ltd, Operator input) throw } } } + + for (Operator parent : (List>)input.getParentOperators()) { + setWriteIdForSurrogateKeys(ltd, parent); + } } private WriteEntity generateTableWriteEntity(String dest, Table dest_tab,