diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java index 1f6dc04..cfc1501 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java @@ -55,6 +55,7 @@ public SparkHashTableSinkOperator() { protected void initializeOp(Configuration hconf) throws HiveException { ObjectInspector[] inputOIs = new ObjectInspector[conf.getTagLength()]; inputOIs[tag] = inputObjInspectors[0]; + conf.setTagOrder(new Byte[]{ tag }); htsOperator.setConf(conf); htsOperator.initialize(hconf, inputOIs); }