From 531d6bd65a1d53e7d221ad627af9e7fb8f35f1cb Mon Sep 17 00:00:00 2001
From: Sean Busbey <busbey@cloudera.com>
Date: Sun, 24 Jan 2016 03:32:51 -0600
Subject: [PATCH] [accumulo] correct cleanup to only happen once per jvm.
closes #340
---
.../com/yahoo/ycsb/db/accumulo/AccumuloClient.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/accumulo/src/main/java/com/yahoo/ycsb/db/accumulo/AccumuloClient.java b/accumulo/src/main/java/com/yahoo/ycsb/db/accumulo/AccumuloClient.java
index 9f3448d8..96b869e2 100644
--- a/accumulo/src/main/java/com/yahoo/ycsb/db/accumulo/AccumuloClient.java
+++ b/accumulo/src/main/java/com/yahoo/ycsb/db/accumulo/AccumuloClient.java
@@ -63,6 +63,16 @@ public class AccumuloClient extends DB {
private Scanner singleScanner = null; // A scanner for reads/deletes.
private Scanner scanScanner = null; // A scanner for use by scan()
+ static {
+
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ @Override
+ public void run() {
+ CleanUp.shutdownNow();
+ }
+ });
+ }
+
@Override
public void init() throws DBException {
colFam = new Text(getProperties().getProperty("accumulo.columnFamily"));
@@ -96,7 +106,6 @@ public class AccumuloClient extends DB {
} catch (MutationsRejectedException e) {
throw new DBException(e);
}
- CleanUp.shutdownNow();
}
/**
--
GitLab