Skip to content
Snippets Groups Projects
Commit 3d3b5a77 authored by Sean Busbey's avatar Sean Busbey
Browse files

[accumulo] correct client to use proposed table name instead of last table name.

parent d1b680ed
No related branches found
No related tags found
No related merge requests found
......@@ -169,11 +169,11 @@ public class AccumuloClient extends DB {
bwc.setMaxWriteThreads(Integer.parseInt(
getProperties().getProperty("accumulo.batchWriterThreads", "1")));
bw = connector.createBatchWriter(table, bwc);
bw = connector.createBatchWriter(t, bwc);
// Create our scanners
singleScanner = connector.createScanner(table, Authorizations.EMPTY);
scanScanner = connector.createScanner(table, Authorizations.EMPTY);
singleScanner = connector.createScanner(t, Authorizations.EMPTY);
scanScanner = connector.createScanner(t, Authorizations.EMPTY);
table = t; // Store the name of the table we have open.
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment