-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33251/
-----------------------------------------------------------
Review request for hive, Chao Sun, Szehon Ho, and Xuefu Zhang.
Bugs: HIVE-10302
https://issues.apache.org/jira/browse/HIVE-10302
Repository: hive-git
Description
-------
Cached the small table containter so that mapjoin tasks can use it if the task
is executed on the same Spark executor.
The cache is released right after the next job assuming the mapjoin job follows
the small table sink job.
Diffs
-----
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HashTableLoader.java fe108c4
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java
7e33a3f
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/RemoteHiveSparkClient.java
059016d
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkRecordHandler.java
97b3471
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkUtilities.java 72ab913
Diff: https://reviews.apache.org/r/33251/diff/
Testing
-------
Ran several queries in live cluster. ptest pending.
Thanks,
Jimmy Xiang
