You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2014/01/28 20:22:46 UTC
[2/3] git commit: ACCUMULO-1961 removing trivial warnings
ACCUMULO-1961 removing trivial warnings
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/f1ae5a86
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/f1ae5a86
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/f1ae5a86
Branch: refs/heads/1.6.0-SNAPSHOT
Commit: f1ae5a860bf7a32efc744adb52f54d1a394fd6b0
Parents: 772ca16
Author: Eric Newton <er...@gmail.com>
Authored: Tue Jan 28 14:18:25 2014 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Jan 28 14:18:25 2014 -0500
----------------------------------------------------------------------
.../org/apache/accumulo/core/client/impl/OfflineScanner.java | 2 --
.../core/client/mapreduce/lib/util/ConfiguratorBase.java | 2 --
.../main/java/org/apache/accumulo/server/master/Master.java | 6 ++----
.../org/apache/accumulo/test/continuous/ContinuousVerify.java | 1 -
.../main/java/org/apache/accumulo/test/randomwalk/State.java | 1 -
5 files changed, 2 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/f1ae5a86/core/src/main/java/org/apache/accumulo/core/client/impl/OfflineScanner.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/client/impl/OfflineScanner.java b/core/src/main/java/org/apache/accumulo/core/client/impl/OfflineScanner.java
index 5f3069a..e00fcc8 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/impl/OfflineScanner.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/impl/OfflineScanner.java
@@ -22,12 +22,10 @@ import java.util.Arrays;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
-import java.util.Map;
import java.util.Map.Entry;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
-import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.client.RowIterator;
http://git-wip-us.apache.org/repos/asf/accumulo/blob/f1ae5a86/core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/util/ConfiguratorBase.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/util/ConfiguratorBase.java b/core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/util/ConfiguratorBase.java
index b1ae3a5..cb54856 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/util/ConfiguratorBase.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/util/ConfiguratorBase.java
@@ -23,8 +23,6 @@ import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.client.ZooKeeperInstance;
import org.apache.accumulo.core.client.mock.MockInstance;
import org.apache.accumulo.core.client.security.tokens.AuthenticationToken;
-import org.apache.accumulo.core.conf.AccumuloConfiguration;
-import org.apache.accumulo.core.conf.SiteConfiguration;
import org.apache.accumulo.core.security.CredentialHelper;
import org.apache.accumulo.core.util.ArgumentChecker;
import org.apache.commons.codec.binary.Base64;
http://git-wip-us.apache.org/repos/asf/accumulo/blob/f1ae5a86/server/src/main/java/org/apache/accumulo/server/master/Master.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/accumulo/server/master/Master.java b/server/src/main/java/org/apache/accumulo/server/master/Master.java
index 33919f7..396c219 100644
--- a/server/src/main/java/org/apache/accumulo/server/master/Master.java
+++ b/server/src/main/java/org/apache/accumulo/server/master/Master.java
@@ -1455,9 +1455,7 @@ public class Master implements LiveTServerSet.Listener, TableObserver, CurrentSt
try {
Map<Key, Value> future = new HashMap<Key, Value>();
Map<Key, Value> assigned = new HashMap<Key, Value>();
- KeyExtent extent = new KeyExtent(row, new Value(new byte[]{0}));
- String table = Constants.METADATA_TABLE_NAME;
- Scanner scanner = getConnector().createScanner(table, Constants.NO_AUTHS);
+ Scanner scanner = getConnector().createScanner(Constants.METADATA_TABLE_NAME, Constants.NO_AUTHS);
scanner.fetchColumnFamily(Constants.METADATA_CURRENT_LOCATION_COLUMN_FAMILY);
scanner.fetchColumnFamily(Constants.METADATA_FUTURE_LOCATION_COLUMN_FAMILY);
scanner.setRange(new Range(row));
@@ -1485,7 +1483,7 @@ public class Master implements LiveTServerSet.Listener, TableObserver, CurrentSt
TServerInstance alive = tserverSet.find(entry.getValue().toString());
if (alive == null) {
Master.log.info("Removing entry " + entry);
- BatchWriter bw = getConnector().createBatchWriter(table, new BatchWriterConfig());
+ BatchWriter bw = getConnector().createBatchWriter(Constants.METADATA_TABLE_NAME, new BatchWriterConfig());
Mutation m = new Mutation(entry.getKey().getRow());
m.putDelete(entry.getKey().getColumnFamily(), entry.getKey().getColumnQualifier());
bw.addMutation(m);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/f1ae5a86/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
index c82d03b..e0c2fe5 100644
--- a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
+++ b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
@@ -18,7 +18,6 @@ package org.apache.accumulo.test.continuous;
import java.io.IOException;
import java.lang.reflect.Method;
-import java.net.URI;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
http://git-wip-us.apache.org/repos/asf/accumulo/blob/f1ae5a86/test/src/main/java/org/apache/accumulo/test/randomwalk/State.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/randomwalk/State.java b/test/src/main/java/org/apache/accumulo/test/randomwalk/State.java
index b799d04..ae100cb 100644
--- a/test/src/main/java/org/apache/accumulo/test/randomwalk/State.java
+++ b/test/src/main/java/org/apache/accumulo/test/randomwalk/State.java
@@ -28,7 +28,6 @@ import org.apache.accumulo.core.client.BatchWriterConfig;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.client.MultiTableBatchWriter;
-import org.apache.accumulo.core.client.MutationsRejectedException;
import org.apache.accumulo.core.client.ZooKeeperInstance;
import org.apache.accumulo.core.client.security.tokens.AuthenticationToken;
import org.apache.accumulo.core.client.security.tokens.PasswordToken;