Skip to content
Permalink
Browse files
Fix #88 incorrect argument array indexes (#95)
Update reference to correct position in array for the table name.
  • Loading branch information
lbschanno authored and ctubbsii committed Jul 16, 2019
1 parent 28492f4 commit 5a0ac28a89fc4ed9fa7e0cdf633f9d065a6a0cbb
Showing 1 changed file with 4 additions and 4 deletions.
@@ -38,14 +38,14 @@ public void visit(State state, RandWalkEnv env, Properties props) throws Excepti
String[] args = new String[3];
args[0] = env.getClientPropsPath();
args[1] = state.getString("seqTableName");
args[2] = args[2] + "_MR";
args[2] = args[1] + "_MR";

if (ToolRunner.run(env.getHadoopConfiguration(), new MapRedVerifyTool(), args) != 0) {
log.error("Failed to run map/red verify");
return;
}

Scanner outputScanner = env.getAccumuloClient().createScanner(args[5], Authorizations.EMPTY);
Scanner outputScanner = env.getAccumuloClient().createScanner(args[2], Authorizations.EMPTY);
outputScanner.setRange(new Range());

int count = 0;
@@ -63,8 +63,8 @@ public void visit(State state, RandWalkEnv env, Properties props) throws Excepti
log.error("Gaps in output");
}

log.debug("Dropping table: " + args[5]);
log.debug("Dropping table: " + args[2]);
AccumuloClient client = env.getAccumuloClient();
client.tableOperations().delete(args[5]);
client.tableOperations().delete(args[2]);
}
}

0 comments on commit 5a0ac28

Please sign in to comment.