From 3d3b5a774ee32b85caf1a42b1094c4d8d50f987d Mon Sep 17 00:00:00 2001
From: Sean Busbey <busbey@cloudera.com>
Date: Mon, 4 Jan 2016 01:59:35 -0600
Subject: [PATCH] [accumulo] correct client to use proposed table name instead
of last table name.
---
.../src/main/java/com/yahoo/ycsb/db/AccumuloClient.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java b/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java
index db78e879..6886307c 100644
--- a/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java
+++ b/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java
@@ -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.
}
--
GitLab