----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28017/ -----------------------------------------------------------
Review request for hive, Jimmy Xiang, Szehon Ho, and Xuefu Zhang. Bugs: HIVE-8776 https://issues.apache.org/jira/browse/HIVE-8776 Repository: hive-git Description ------- In SparkMapJoinResolver, we need to populate MapredLocalWork for all MapWorks with MapJoinOperator. It is needed later in HashTableLoader, for example, to retrieve small hash tables and direct fetch tables. We need to set up information, such as aliasToWork, aliasToFetchWork, directFetchOp, inputFileChangeSensitive, tmpPath, etc., for the new local works. Diffs ----- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HashTableLoader.java d30ae51 ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/SparkMapJoinResolver.java 4b9a6cb ql/src/java/org/apache/hadoop/hive/ql/plan/MapredLocalWork.java 785e4a0 Diff: https://reviews.apache.org/r/28017/diff/ Testing ------- Thanks, Chao Sun