diff --git a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java index 50e022d..c0eff23 100644 --- a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java +++ b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java @@ -76,6 +76,8 @@ import org.apache.hadoop.util.StringUtils; import org.apache.zookeeper.KeeperException; +import com.yammer.metrics.core.MetricsRegistry; + /** * HBaseStorageHandler provides a HiveStorageHandler implementation for * HBase. @@ -512,6 +514,10 @@ public void configureJobConf(TableDesc tableDesc, JobConf jobConf) { TableMapReduceUtil.addDependencyJars( jobConf, HBaseStorageHandler.class, TableInputFormatBase.class); } + if (HiveConf.getVar(jobConf, HiveConf.ConfVars.HIVE_HBASE_SNAPSHOT_NAME) != null) { + // There is an extra dependency on MetricsRegistry for snapshot IF. + TableMapReduceUtil.addDependencyJars(jobConf, MetricsRegistry.class); + } Set merged = new LinkedHashSet(jobConf.getStringCollection("tmpjars")); Job copy = new Job(jobConf);