HBASE-17826 Backup: submit M/R job to a particular Yarn queue - addendum fixes variable name (Vladimir Rodionov)
This commit is contained in:
parent
fb537fe736
commit
7a1c121678
|
@ -324,9 +324,9 @@ public final class BackupCommands {
|
||||||
.getOptionValue(OPTION_WORKERS)) : -1;
|
.getOptionValue(OPTION_WORKERS)) : -1;
|
||||||
|
|
||||||
if (cmdline.hasOption(OPTION_YARN_QUEUE_NAME)) {
|
if (cmdline.hasOption(OPTION_YARN_QUEUE_NAME)) {
|
||||||
String poolName = cmdline.getOptionValue(OPTION_YARN_QUEUE_NAME);
|
String queueName = cmdline.getOptionValue(OPTION_YARN_QUEUE_NAME);
|
||||||
// Set system property value for MR job
|
// Set system property value for MR job
|
||||||
System.setProperty("mapreduce.job.queuename", poolName);
|
System.setProperty("mapreduce.job.queuename", queueName);
|
||||||
}
|
}
|
||||||
|
|
||||||
try (BackupAdminImpl admin = new BackupAdminImpl(conn);) {
|
try (BackupAdminImpl admin = new BackupAdminImpl(conn);) {
|
||||||
|
|
Loading…
Reference in New Issue