HBASE-16007 Job's Configuration should be passed to TableMapReduceUtil#addDependencyJars() in WALPlayer
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/6360cc03 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/6360cc03 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/6360cc03 Branch: refs/heads/hbase-12439 Commit: 6360cc0307518501faac114a9cce58ef19eeca0c Parents: 4c885f4 Author: tedyu <[email protected]> Authored: Sat Jun 11 07:05:27 2016 -0700 Committer: Ted <[email protected]> Committed: Sat Jun 11 07:05:27 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/6360cc03/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java index d36721e..c6fefb2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALPlayer.java @@ -295,7 +295,7 @@ public class WALPlayer extends Configured implements Tool { } String codecCls = WALCellCodec.getWALCellCodecClass(conf); try { - TableMapReduceUtil.addDependencyJars(conf, Class.forName(codecCls)); + TableMapReduceUtil.addDependencyJars(job.getConfiguration(), Class.forName(codecCls)); } catch (Exception e) { throw new IOException("Cannot determine wal codec class " + codecCls, e); }
