diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TsvImporterMapper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TsvImporterMapper.java index 94bcb43..ddc2ad2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TsvImporterMapper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TsvImporterMapper.java @@ -107,6 +107,12 @@ extends Mapper doSetup(context); conf = context.getConfiguration(); + try { + TableMapReduceUtil.addDependencyJars(conf, + org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.class); + } catch (IOException ioe) { + throw new RuntimeException("Couldn't add dependency", ioe); + } parser = new ImportTsv.TsvParser(conf.get(ImportTsv.COLUMNS_CONF_KEY), separator); if (parser.getRowKeyColumnIndex() == -1) {