This is an automated email from the ASF dual-hosted git repository.
domgarguilo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/main by this push:
new 67127d8 Correct user-facing misspellings (#2400)
67127d8 is described below
commit 67127d81a03a693adbde7791605e1f6f57f9ba29
Author: Luke Foster <84727868+foste...@users.noreply.github.com>
AuthorDate: Tue Dec 28 09:47:19 2021 -0500
Correct user-facing misspellings (#2400)
* Fix user-facing misspellings
---
.github/CONTRIBUTING.md | 2 +-
.../main/java/org/apache/accumulo/core/client/rfile/RFileWriter.java | 2 +-
.../org/apache/accumulo/core/clientImpl/NamespaceOperationsImpl.java | 2 +-
.../java/org/apache/accumulo/core/clientImpl/TableOperationsImpl.java | 2 +-
.../org/apache/accumulo/core/crypto/streams/BlockedInputStream.java | 2 +-
.../src/main/java/org/apache/accumulo/core/file/BloomFilterLayer.java | 2 +-
core/src/main/java/org/apache/accumulo/core/file/rfile/RFile.java | 2 +-
.../main/java/org/apache/accumulo/core/file/rfile/bcfile/Utils.java | 2 +-
core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java | 2 +-
.../accumulo/core/iteratorsImpl/system/SourceSwitchingIterator.java | 2 +-
.../org/apache/accumulo/core/metadata/schema/LinkingIterator.java | 2 +-
.../apache/accumulo/core/spi/compaction/DefaultCompactionPlanner.java | 2 +-
core/src/main/java/org/apache/accumulo/core/util/AddressUtil.java | 4 ++--
.../org/apache/accumulo/fate/zookeeper/DistributedReadWriteLock.java | 2 +-
.../org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java | 2 +-
.../apache/accumulo/hadoopImpl/mapreduce/lib/MapReduceClientOpts.java | 2 +-
.../main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java | 4 ++--
.../server/replication/DistributedWorkQueueWorkAssignerHelper.java | 2 +-
.../src/main/java/org/apache/accumulo/server/rpc/TServerUtils.java | 2 +-
.../java/org/apache/accumulo/server/security/SecurityOperation.java | 2 +-
.../main/java/org/apache/accumulo/server/security/SecurityUtil.java | 2 +-
.../server/security/delegation/AuthenticationTokenSecretManager.java | 2 +-
.../accumulo/server/security/handler/KerberosAuthenticator.java | 2 +-
.../src/main/java/org/apache/accumulo/server/tables/TableManager.java | 2 +-
.../src/main/java/org/apache/accumulo/server/util/ListInstances.java | 2 +-
.../java/org/apache/accumulo/coordinator/CompactionFinalizer.java | 2 +-
.../java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java | 2 +-
server/manager/pom.xml | 2 +-
.../accumulo/manager/replication/ManagerReplicationCoordinator.java | 2 +-
.../java/org/apache/accumulo/tserver/TabletServerResourceManager.java | 2 +-
.../apache/accumulo/tserver/replication/AccumuloReplicaSystem.java | 2 +-
.../src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java | 2 +-
.../main/java/org/apache/accumulo/shell/commands/CompactCommand.java | 4 ++--
.../org/apache/accumulo/shell/commands/ListCompactionsCommand.java | 2 +-
.../start/classloader/vfs/AccumuloReloadingVFSClassLoader.java | 2 +-
test/src/main/java/org/apache/accumulo/test/TestIngest.java | 2 +-
.../org/apache/accumulo/test/compaction/CompactionExecutorIT.java | 4 ++--
.../java/org/apache/accumulo/test/functional/BatchWriterFlushIT.java | 2 +-
.../main/java/org/apache/accumulo/test/functional/ConstraintIT.java | 2 +-
test/src/main/java/org/apache/accumulo/test/functional/MaxOpenIT.java | 4 ++--
.../main/java/org/apache/accumulo/test/functional/PermissionsIT.java | 4 ++--
.../main/java/org/apache/accumulo/test/functional/ScanIteratorIT.java | 2 +-
test/src/main/java/org/apache/accumulo/test/functional/SummaryIT.java | 2 +-
.../java/org/apache/accumulo/test/functional/YieldingIterator.java | 2 +-
.../apache/accumulo/test/replication/ReplicationOperationsImplIT.java | 2 +-
45 files changed, 51 insertions(+), 51 deletions(-)
diff --git a/.github/CONTRIBUTING.md b/.github/CONTRIBUTING.md
index 2329f9c..76d397a 100644
--- a/.github/CONTRIBUTING.md
+++ b/.github/CONTRIBUTING.md
@@ -17,7 +17,7 @@ limitations under the License.
# Contributors Guide
-If you believe that you have found a
[bug](https://github.com/apache/accumulo/labels/bug), please search for an
existing [issue](https://github.com/apache/accumulo/issues) to see if it has
already been reported. If you would like to add a new feature to Accumulo,
please send an email with your idea to the
[dev](mailto:d...@accumulo.apache.org) mail list. If it's appropriate, then we
will create an issue. For simple changes, its ok to just submit a pull request
without an issue.
+If you believe that you have found a
[bug](https://github.com/apache/accumulo/labels/bug), please search for an
existing [issue](https://github.com/apache/accumulo/issues) to see if it has
already been reported. If you would like to add a new feature to Accumulo,
please send an email with your idea to the
[dev](mailto:d...@accumulo.apache.org) mail list. If it's appropriate, then we
will create an issue. For simple changes, it's ok to just submit a pull
request without an issue.
## Development
diff --git
a/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileWriter.java
b/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileWriter.java
index 0bae223..7d1a30c 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileWriter.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileWriter.java
@@ -103,7 +103,7 @@ public class RFileWriter implements AutoCloseable {
private void _startNewLocalityGroup(String name, Set<ByteSequence>
columnFamilies)
throws IOException {
Preconditions.checkState(!startedDefaultLG,
- "Cannont start a locality group after starting the default locality
group");
+ "Cannot start a locality group after starting the default locality
group");
writer.startNewLocalityGroup(name, columnFamilies);
startedLG = true;
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/clientImpl/NamespaceOperationsImpl.java
b/core/src/main/java/org/apache/accumulo/core/clientImpl/NamespaceOperationsImpl.java
index c95cc87..2c95c2f 100644
---
a/core/src/main/java/org/apache/accumulo/core/clientImpl/NamespaceOperationsImpl.java
+++
b/core/src/main/java/org/apache/accumulo/core/clientImpl/NamespaceOperationsImpl.java
@@ -109,7 +109,7 @@ public class NamespaceOperationsImpl extends
NamespaceOperationsHelper {
if (timer != null) {
timer.stop();
- log.trace("tid={} Checked existance of {} in {}",
Thread.currentThread().getId(), exists,
+ log.trace("tid={} Checked existence of {} in {}",
Thread.currentThread().getId(), exists,
String.format("%.3f secs", timer.scale(TimeUnit.SECONDS)));
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/clientImpl/TableOperationsImpl.java
b/core/src/main/java/org/apache/accumulo/core/clientImpl/TableOperationsImpl.java
index 202860a..21ef77d 100644
---
a/core/src/main/java/org/apache/accumulo/core/clientImpl/TableOperationsImpl.java
+++
b/core/src/main/java/org/apache/accumulo/core/clientImpl/TableOperationsImpl.java
@@ -207,7 +207,7 @@ public class TableOperationsImpl extends
TableOperationsHelper {
if (timer != null) {
timer.stop();
- log.trace("tid={} Checked existance of {} in {}",
Thread.currentThread().getId(), exists,
+ log.trace("tid={} Checked existence of {} in {}",
Thread.currentThread().getId(), exists,
String.format("%.3f secs", timer.scale(TimeUnit.SECONDS)));
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/crypto/streams/BlockedInputStream.java
b/core/src/main/java/org/apache/accumulo/core/crypto/streams/BlockedInputStream.java
index e1db80a..269518b 100644
---
a/core/src/main/java/org/apache/accumulo/core/crypto/streams/BlockedInputStream.java
+++
b/core/src/main/java/org/apache/accumulo/core/crypto/streams/BlockedInputStream.java
@@ -65,7 +65,7 @@ public class BlockedInputStream extends InputStream {
readPos = 0;
else if (readPos > array.length)
throw new RuntimeException(
- "Unexpected state, this should only ever increase or cycle on the
boundry!");
+ "Unexpected state, this should only ever increase or cycle on the
boundary!");
return toRet;
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/file/BloomFilterLayer.java
b/core/src/main/java/org/apache/accumulo/core/file/BloomFilterLayer.java
index 48b69be..cc9ca6d 100644
--- a/core/src/main/java/org/apache/accumulo/core/file/BloomFilterLayer.java
+++ b/core/src/main/java/org/apache/accumulo/core/file/BloomFilterLayer.java
@@ -544,7 +544,7 @@ public class BloomFilterLayer {
t2 = System.currentTimeMillis();
- out.printf("existant lookup rate %6.2f%n", 500 / ((t2 - t1) / 1000.0));
+ out.printf("existing lookup rate %6.2f%n", 500 / ((t2 - t1) / 1000.0));
out.println("expected hits 500. Receive hits: " + count);
bmfr.close();
}
diff --git a/core/src/main/java/org/apache/accumulo/core/file/rfile/RFile.java
b/core/src/main/java/org/apache/accumulo/core/file/rfile/RFile.java
index d0349f4..eb457c8 100644
--- a/core/src/main/java/org/apache/accumulo/core/file/rfile/RFile.java
+++ b/core/src/main/java/org/apache/accumulo/core/file/rfile/RFile.java
@@ -655,7 +655,7 @@ public class RFile {
public void append(Key key, Value value) throws IOException {
if (dataClosed) {
- throw new IllegalStateException("Cannont append, data closed");
+ throw new IllegalStateException("Cannot append, data closed");
}
lgWriter.append(key, value);
diff --git
a/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/Utils.java
b/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/Utils.java
index 452fed3..3627f65 100644
--- a/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/Utils.java
+++ b/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/Utils.java
@@ -146,7 +146,7 @@ public final class Utils {
out.writeLong(n);
return;
default:
- throw new RuntimeException("Internel error");
+ throw new RuntimeException("Internal error");
}
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
b/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
index c943a8e..5126d42 100644
--- a/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
+++ b/core/src/main/java/org/apache/accumulo/core/iterators/Combiner.java
@@ -193,7 +193,7 @@ public abstract class Combiner extends WrappingIterator
implements OptionDescrib
sawDeleteLog.error(
"Combiner of type {} saw a delete during a"
+ " partial compaction. This could cause undesired results.
See"
- + " ACCUMULO-2232. Will not log subsequent occurences for at
least" + " 1 hour.",
+ + " ACCUMULO-2232. Will not log subsequent occurrences for
at least" + " 1 hour.",
Combiner.this.getClass().getSimpleName());
// the value is not used and does not matter
return Boolean.TRUE;
diff --git
a/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/system/SourceSwitchingIterator.java
b/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/system/SourceSwitchingIterator.java
index a2ed282..27bf74e 100644
---
a/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/system/SourceSwitchingIterator.java
+++
b/core/src/main/java/org/apache/accumulo/core/iteratorsImpl/system/SourceSwitchingIterator.java
@@ -237,7 +237,7 @@ public class SourceSwitchingIterator implements
InterruptibleIterator {
private void _switchNow() throws IOException {
if (onlySwitchAfterRow)
- throw new IllegalStateException("Can only switch on row boundries");
+ throw new IllegalStateException("Can only switch on row boundaries");
if (switchSource()) {
if (key != null) {
diff --git
a/core/src/main/java/org/apache/accumulo/core/metadata/schema/LinkingIterator.java
b/core/src/main/java/org/apache/accumulo/core/metadata/schema/LinkingIterator.java
index 5cdbb00..5efe356 100644
---
a/core/src/main/java/org/apache/accumulo/core/metadata/schema/LinkingIterator.java
+++
b/core/src/main/java/org/apache/accumulo/core/metadata/schema/LinkingIterator.java
@@ -72,7 +72,7 @@ public class LinkingIterator implements
Iterator<TabletMetadata> {
Text defaultTabletRow =
TabletsSection.encodeRow(prevTablet.getTableId(), null);
if (range.contains(new Key(defaultTabletRow))) {
throw new IllegalStateException(
- "Scan range incudled default tablet, but did not see default
tablet. Last tablet seen : "
+ "Scan range included default tablet, but did not see default
tablet. Last tablet seen : "
+ prevTablet.getExtent());
}
}
diff --git
a/core/src/main/java/org/apache/accumulo/core/spi/compaction/DefaultCompactionPlanner.java
b/core/src/main/java/org/apache/accumulo/core/spi/compaction/DefaultCompactionPlanner.java
index 7046bd8..a74ab37 100644
---
a/core/src/main/java/org/apache/accumulo/core/spi/compaction/DefaultCompactionPlanner.java
+++
b/core/src/main/java/org/apache/accumulo/core/spi/compaction/DefaultCompactionPlanner.java
@@ -217,7 +217,7 @@ public class DefaultCompactionPlanner implements
CompactionPlanner {
&& params.getServiceEnvironment().getConfiguration()
.isSet(Property.TSERV_MAJC_THREAD_MAXOPEN.getKey())) {
log.warn("The property " + Property.TSERV_MAJC_THREAD_MAXOPEN.getKey()
- + " was set, it is deperecated. Set the " + fqo + " option
instead.");
+ + " was set, it is deprecated. Set the " + fqo + " option
instead.");
this.maxFilesToCompact =
Integer.parseInt(params.getServiceEnvironment().getConfiguration()
.get(Property.TSERV_MAJC_THREAD_MAXOPEN.getKey()));
} else {
diff --git a/core/src/main/java/org/apache/accumulo/core/util/AddressUtil.java
b/core/src/main/java/org/apache/accumulo/core/util/AddressUtil.java
index 6975acc..341d2ca 100644
--- a/core/src/main/java/org/apache/accumulo/core/util/AddressUtil.java
+++ b/core/src/main/java/org/apache/accumulo/core/util/AddressUtil.java
@@ -61,7 +61,7 @@ public class AddressUtil {
try {
negativeTtl =
Integer.parseInt(Security.getProperty("networkaddress.cache.negative.ttl"));
} catch (NumberFormatException exception) {
- log.warn("Failed to get JVM negative DNS respones cache TTL due to
format problem "
+ log.warn("Failed to get JVM negative DNS response cache TTL due to
format problem "
+ "(e.g. this JVM might not have the property). "
+ "Falling back to default based on Oracle JVM 1.4+ (10s)",
exception);
} catch (SecurityException exception) {
@@ -70,7 +70,7 @@ public class AddressUtil {
}
if (negativeTtl == -1) {
log.error(
- "JVM negative DNS repsonse cache TTL is set to 'forever' and host
lookup failed. "
+ "JVM negative DNS response cache TTL is set to 'forever' and host
lookup failed. "
+ "TTL can be changed with security property "
+ "'networkaddress.cache.negative.ttl', see
java.net.InetAddress.",
originalException);
diff --git
a/core/src/main/java/org/apache/accumulo/fate/zookeeper/DistributedReadWriteLock.java
b/core/src/main/java/org/apache/accumulo/fate/zookeeper/DistributedReadWriteLock.java
index b0db7b4..5e424cb 100644
---
a/core/src/main/java/org/apache/accumulo/fate/zookeeper/DistributedReadWriteLock.java
+++
b/core/src/main/java/org/apache/accumulo/fate/zookeeper/DistributedReadWriteLock.java
@@ -149,7 +149,7 @@ public class DistributedReadWriteLock implements
java.util.concurrent.locks.Read
public boolean tryLock() {
if (entry == -1) {
entry = qlock.addEntry(new ParsedLock(this.lockType(),
this.userData).getLockData());
- log.info("Added lock entry {} userData {} lockTpye {}", entry,
+ log.info("Added lock entry {} userData {} lockType {}", entry,
new String(this.userData, UTF_8), lockType());
}
SortedMap<Long,byte[]> entries = qlock.getEarlierEntries(entry);
diff --git
a/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
b/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
index 1b8177e..1ff5a5f 100644
---
a/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
+++
b/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
@@ -138,7 +138,7 @@ public class BloomFilterLayerLookupTest {
t2 = System.currentTimeMillis();
double rate2 = 500 / ((t2 - t1) / 1000.0);
- log.debug(String.format("existant lookup rate %6.2f%n", rate2));
+ log.debug(String.format("existing lookup rate %6.2f%n", rate2));
log.debug("expected hits 500. Receive hits: {}", count);
bmfr.close();
diff --git
a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/MapReduceClientOpts.java
b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/MapReduceClientOpts.java
index 0e24063..d05244b 100644
---
a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/MapReduceClientOpts.java
+++
b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/MapReduceClientOpts.java
@@ -67,7 +67,7 @@ public class MapReduceClientOpts extends ClientOpts {
if (!client.securityOperations().hasSystemPermission(client.whoami(),
SystemPermission.OBTAIN_DELEGATION_TOKEN)) {
log.error(
- "{} doesn't have the {} SystemPermission neccesary to obtain a
delegation"
+ "{} doesn't have the {} SystemPermission necessary to obtain a
delegation"
+ " token. MapReduce tasks cannot automatically use the
client's"
+ " credentials on remote servers. Delegation tokens
provide a means to run"
+ " MapReduce without distributing the user's
credentials.",
diff --git
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
index 014e4c3..5cb81b5 100644
---
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
+++
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
@@ -87,7 +87,7 @@ public class MiniAccumuloRunner {
private static void printProperties() {
System.out.println("#mini Accumulo cluster runner properties.");
System.out.println("#");
- System.out.println("#uncomment following propeties to use, propeties not"
+ System.out.println("#uncomment following properties to use, properties not"
+ " set will use default or random value");
System.out.println();
System.out.println("#" + INSTANCE_NAME_PROP + "=devTest");
@@ -142,7 +142,7 @@ public class MiniAccumuloRunner {
Properties prop = new Properties();
@Parameter(names = {"-c", "--printProperties"}, required = false,
- description = "prints an example propeties file, redirect to file to
use")
+ description = "prints an example properties file, redirect to file to
use")
boolean printProps = false;
}
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/replication/DistributedWorkQueueWorkAssignerHelper.java
b/server/base/src/main/java/org/apache/accumulo/server/replication/DistributedWorkQueueWorkAssignerHelper.java
index be1a8b6..d1b9851 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/replication/DistributedWorkQueueWorkAssignerHelper.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/replication/DistributedWorkQueueWorkAssignerHelper.java
@@ -73,7 +73,7 @@ public class DistributedWorkQueueWorkAssignerHelper {
int thirdIndex = queueKey.indexOf(KEY_SEPARATOR, secondIndex + 1);
if (thirdIndex == -1) {
throw new IllegalArgumentException(
- "Could not find expected seperator in queue key '" + queueKey + "'");
+ "Could not find expected separator in queue key '" + queueKey + "'");
}
return Maps.immutableEntry(filename,
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/rpc/TServerUtils.java
b/server/base/src/main/java/org/apache/accumulo/server/rpc/TServerUtils.java
index fb97beb..48fee3b 100644
--- a/server/base/src/main/java/org/apache/accumulo/server/rpc/TServerUtils.java
+++ b/server/base/src/main/java/org/apache/accumulo/server/rpc/TServerUtils.java
@@ -430,7 +430,7 @@ public class TServerUtils {
if (socketEnabledProtocols.isEmpty()) {
// Bad configuration...
throw new RuntimeException(
- "No available protocols available for secure socket. Availaable
protocols: "
+ "No available protocols available for secure socket. Available
protocols: "
+ Arrays.toString(sslServerSock.getEnabledProtocols()) + ",
allowed protocols: "
+ Arrays.toString(protocols));
}
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/security/SecurityOperation.java
b/server/base/src/main/java/org/apache/accumulo/server/security/SecurityOperation.java
index ebc86df..07a6231 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/security/SecurityOperation.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/security/SecurityOperation.java
@@ -127,7 +127,7 @@ public class SecurityOperation {
|| !authenticator.validSecurityHandlers()
|| !permHandle.validSecurityHandlers(authent, author))
throw new RuntimeException(authorizor + ", " + authenticator + ", and "
+ pm
- + " do not play nice with eachother. Please choose authentication
and"
+ + " do not play nice with each other. Please choose authentication
and"
+ " authorization mechanisms that are compatible with one another.");
isKerberos =
KerberosAuthenticator.class.isAssignableFrom(authenticator.getClass());
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/security/SecurityUtil.java
b/server/base/src/main/java/org/apache/accumulo/server/security/SecurityUtil.java
index 98bb6a2..d5ae21e 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/security/SecurityUtil.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/security/SecurityUtil.java
@@ -92,7 +92,7 @@ public class SecurityUtil {
&& !principalName.isEmpty()) {
log.info("Attempting to login with keytab as {}", principalName);
UserGroupInformation.loginUserFromKeytab(principalName, keyTabPath);
- log.info("Succesfully logged in as user {}", principalName);
+ log.info("Successfully logged in as user {}", principalName);
return true;
}
} catch (IOException io) {
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/security/delegation/AuthenticationTokenSecretManager.java
b/server/base/src/main/java/org/apache/accumulo/server/security/delegation/AuthenticationTokenSecretManager.java
index f700158..7b8a439 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/security/delegation/AuthenticationTokenSecretManager.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/security/delegation/AuthenticationTokenSecretManager.java
@@ -204,7 +204,7 @@ public class AuthenticationTokenSecretManager extends
SecretManager<Authenticati
synchronized boolean removeKey(Integer keyId) {
requireNonNull(keyId);
- log.debug("Removing AuthenticatioKey with keyId {}", keyId);
+ log.debug("Removing AuthenticationKey with keyId {}", keyId);
return allKeys.remove(keyId) != null;
}
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/security/handler/KerberosAuthenticator.java
b/server/base/src/main/java/org/apache/accumulo/server/security/handler/KerberosAuthenticator.java
index cebdbaa..06313933 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/security/handler/KerberosAuthenticator.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/security/handler/KerberosAuthenticator.java
@@ -175,7 +175,7 @@ public class KerberosAuthenticator implements Authenticator
{
@Override
public void changePassword(String principal, AuthenticationToken token) {
- throw new UnsupportedOperationException("Cannot change password with
Kerberos authenticaton");
+ throw new UnsupportedOperationException("Cannot change password with
Kerberos authentication");
}
@Override
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/tables/TableManager.java
b/server/base/src/main/java/org/apache/accumulo/server/tables/TableManager.java
index 00eb9a4..6aeabab 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/tables/TableManager.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/tables/TableManager.java
@@ -292,7 +292,7 @@ public class TableManager {
}
break;
default:
- log.warn("Unandled {}", event);
+ log.warn("Unhandled {}", event);
}
}
}
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/util/ListInstances.java
b/server/base/src/main/java/org/apache/accumulo/server/util/ListInstances.java
index dbed4c6..ab9d428 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/util/ListInstances.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/util/ListInstances.java
@@ -105,7 +105,7 @@ public class ListInstances {
} else if (!instancedIds.isEmpty()) {
System.out.println();
System.out.println("INFO : " + instancedIds.size()
- + " unamed instances were not printed, run with --print-all to see
all instances");
+ + " unnamed instances were not printed, run with --print-all to see
all instances");
} else {
System.out.println();
}
diff --git
a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionFinalizer.java
b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionFinalizer.java
index bf0ea1b..d196481 100644
---
a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionFinalizer.java
+++
b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionFinalizer.java
@@ -93,7 +93,7 @@ public class CompactionFinalizer {
var ecfs =
new ExternalCompactionFinalState(ecid, extent, FinalState.FINISHED,
fileSize, fileEntries);
- LOG.debug("Initiating commmit for external compaction: {}", ecfs);
+ LOG.debug("Initiating commit for external compaction: {}", ecfs);
// write metadata entry
context.getAmple().putExternalCompactionFinalStates(List.of(ecfs));
diff --git
a/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
b/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
index fcd1edf..7e78259 100644
---
a/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
+++
b/server/gc/src/main/java/org/apache/accumulo/gc/GarbageCollectWriteAheadLogs.java
@@ -229,7 +229,7 @@ public class GarbageCollectWriteAheadLogs {
status.currentLog = new GcCycleStats();
} catch (Exception e) {
- log.error("exception occured while garbage collecting write ahead logs",
e);
+ log.error("exception occurred while garbage collecting write ahead
logs", e);
}
}
diff --git a/server/manager/pom.xml b/server/manager/pom.xml
index a46e717..b161f2e 100644
--- a/server/manager/pom.xml
+++ b/server/manager/pom.xml
@@ -29,7 +29,7 @@
</parent>
<artifactId>accumulo-manager</artifactId>
<name>Apache Accumulo Manager Server</name>
- <description>The manager server for Apache Accumulo for load balacing and
other system-wide operations.</description>
+ <description>The manager server for Apache Accumulo for load balancing and
other system-wide operations.</description>
<dependencies>
<dependency>
<groupId>com.beust</groupId>
diff --git
a/server/manager/src/main/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinator.java
b/server/manager/src/main/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinator.java
index b50e336..5d1f4e7 100644
---
a/server/manager/src/main/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinator.java
+++
b/server/manager/src/main/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinator.java
@@ -89,7 +89,7 @@ public class ManagerReplicationCoordinator implements
ReplicationCoordinator.Ifa
replServiceAddr = new String(reader.getData(manager.getZooKeeperRoot()
+ ReplicationConstants.ZOO_TSERVERS + "/" + tserver.getHostPort()),
UTF_8);
} catch (KeeperException | InterruptedException e) {
- log.error("Could not fetch repliation service port for tserver", e);
+ log.error("Could not fetch replication service port for tserver", e);
throw new ReplicationCoordinatorException(
ReplicationCoordinatorErrorCode.SERVICE_CONFIGURATION_UNAVAILABLE,
"Could not determine port for replication service running at " +
tserver.getHostPort());
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
index 8942f2f..4a5275b 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java
@@ -796,7 +796,7 @@ public class TabletServerResourceManager {
ExecutorService executor = scanExecutors.get(prefs.getExecutorName());
if (executor == null) {
log.warn(
- "For table id {}, {} dispatched to non-existant executor {} Using
default executor.",
+ "For table id {}, {} dispatched to non-existent executor {} Using
default executor.",
tablet.tableId(), dispatcher.getClass().getName(),
prefs.getExecutorName());
executor =
scanExecutors.get(SimpleScanDispatcher.DEFAULT_SCAN_EXECUTOR_NAME);
} else if ("meta".equals(prefs.getExecutorName())) {
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java
index ea99cf1..98d09f4 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java
@@ -669,7 +669,7 @@ public class AccumuloReplicaSystem implements ReplicaSystem
{
}
break;
default:
- log.trace("Ignorning WAL entry which doesn't contain mutations,"
+ log.trace("Ignoring WAL entry which doesn't contain mutations,"
+ " should not have received such entries");
break;
}
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java
index dc28214..d814410 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java
@@ -61,7 +61,7 @@ public abstract class ScanTask<T> implements
RunnableFuture<T> {
public boolean cancel(boolean mayInterruptIfRunning) {
if (!mayInterruptIfRunning)
throw new IllegalArgumentException(
- "Cancel will always attempt to interupt running next batch task");
+ "Cancel will always attempt to interrupt running next batch task");
if (state.get() == CANCELED)
return true;
diff --git
a/shell/src/main/java/org/apache/accumulo/shell/commands/CompactCommand.java
b/shell/src/main/java/org/apache/accumulo/shell/commands/CompactCommand.java
index 6e73669..5315399 100644
--- a/shell/src/main/java/org/apache/accumulo/shell/commands/CompactCommand.java
+++ b/shell/src/main/java/org/apache/accumulo/shell/commands/CompactCommand.java
@@ -254,10 +254,10 @@ public class CompactCommand extends TableOperation {
"Select files that do not have the summaries specified in the table
configuration.");
opts.addOption(enoSummaryOption);
extraSummaryOption = new Option(null, "sf-extra-summary", false,
- "Select files that have summary information which exceeds the tablets
boundries.");
+ "Select files that have summary information which exceeds the tablets
boundaries.");
opts.addOption(extraSummaryOption);
enoSampleOption = new Option(null, "sf-no-sample", false,
- "Select files that have no sample data or sample data that differes"
+ "Select files that have no sample data or sample data that differs"
+ " from the table configuration.");
opts.addOption(enoSampleOption);
enameOption =
diff --git
a/shell/src/main/java/org/apache/accumulo/shell/commands/ListCompactionsCommand.java
b/shell/src/main/java/org/apache/accumulo/shell/commands/ListCompactionsCommand.java
index 78162b8..64611a4 100644
---
a/shell/src/main/java/org/apache/accumulo/shell/commands/ListCompactionsCommand.java
+++
b/shell/src/main/java/org/apache/accumulo/shell/commands/ListCompactionsCommand.java
@@ -35,7 +35,7 @@ public class ListCompactionsCommand extends Command {
@Override
public String description() {
return "lists what compactions are currently running in accumulo. See the"
- + " accumulo.core.client.admin.ActiveCompaciton javadoc for more
information"
+ + " accumulo.core.client.admin.ActiveCompaction javadoc for more
information"
+ " about columns.";
}
diff --git
a/start/src/main/java/org/apache/accumulo/start/classloader/vfs/AccumuloReloadingVFSClassLoader.java
b/start/src/main/java/org/apache/accumulo/start/classloader/vfs/AccumuloReloadingVFSClassLoader.java
index 39a2fda..cf21e5c 100644
---
a/start/src/main/java/org/apache/accumulo/start/classloader/vfs/AccumuloReloadingVFSClassLoader.java
+++
b/start/src/main/java/org/apache/accumulo/start/classloader/vfs/AccumuloReloadingVFSClassLoader.java
@@ -101,7 +101,7 @@ public class AccumuloReloadingVFSClassLoader implements
FileListener, ReloadingC
currentSleepMillis = Math.min(maxWaitInterval,
currentSleepMillis + sleepInterval);
} catch (InterruptedException e) {
- log.error("VFS Retry Interruped", e);
+ log.error("VFS Retry Interrupted", e);
throw new RuntimeException(e);
}
diff --git a/test/src/main/java/org/apache/accumulo/test/TestIngest.java
b/test/src/main/java/org/apache/accumulo/test/TestIngest.java
index 1a9c3e0..a5c32f9 100644
--- a/test/src/main/java/org/apache/accumulo/test/TestIngest.java
+++ b/test/src/main/java/org/apache/accumulo/test/TestIngest.java
@@ -116,7 +116,7 @@ public class TestIngest {
int cols = 1;
@Parameter(names = "--random", description = "insert random rows and use"
- + " the given number to seed the psuedo-random number generator")
+ + " the given number to seed the pseudo-random number generator")
Integer random = null;
@Parameter(names = "--size", description = "the size of the value to
ingest")
diff --git
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionExecutorIT.java
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionExecutorIT.java
index a00541b..59a218e 100644
---
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionExecutorIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionExecutorIT.java
@@ -566,7 +566,7 @@ public class CompactionExecutorIT extends
SharedMiniClusterBase {
.setSelector(new
PluginConfig(CompressionConfigurer.class.getName())).setWait(true));
}).getMessage();
- assertTrue("Unexcpected message : " + msg,
+ assertTrue("Unexpected message : " + msg,
msg.contains("TabletServer could not load CompactionSelector"));
}
@@ -585,7 +585,7 @@ public class CompactionExecutorIT extends
SharedMiniClusterBase {
.setConfigurer(new
PluginConfig(TooManyDeletesSelector.class.getName())).setWait(true));
}).getMessage();
- assertTrue("Unexcpected message : " + msg,
+ assertTrue("Unexpected message : " + msg,
msg.contains("TabletServer could not load CompactionConfigurer"));
}
}
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/BatchWriterFlushIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/BatchWriterFlushIT.java
index 2839698..c008ef7 100644
---
a/test/src/main/java/org/apache/accumulo/test/functional/BatchWriterFlushIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/functional/BatchWriterFlushIT.java
@@ -149,7 +149,7 @@ public class BatchWriterFlushIT extends
AccumuloClusterHarness {
int row = i * NUM_TO_FLUSH + j;
if (!iter.hasNext())
- throw new Exception("Scan stopped permaturely at " + row);
+ throw new Exception("Scan stopped prematurely at " + row);
Entry<Key,Value> entry = iter.next();
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/ConstraintIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/ConstraintIT.java
index f85ef92..ca61f42 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/ConstraintIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/ConstraintIT.java
@@ -188,7 +188,7 @@ public class ConstraintIT extends AccumuloClusterHarness {
// add a constraint that references a non-existent class
client.tableOperations().setProperty(tableName,
Property.TABLE_CONSTRAINT_PREFIX + "1",
- "com.foobar.nonExistantClass");
+ "com.foobar.nonExistentClass");
sleepUninterruptibly(1, TimeUnit.SECONDS);
// add a mutation
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/MaxOpenIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/MaxOpenIT.java
index e550987..12bc710 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/MaxOpenIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/MaxOpenIT.java
@@ -154,13 +154,13 @@ public class MaxOpenIT extends AccumuloClusterHarness {
int col = VerifyIngest.getCol(entry.getKey());
if (row < 0 || row >= NUM_TO_INGEST) {
- throw new Exception("unexcepted row " + row);
+ throw new Exception("unexpected row " + row);
}
rval = TestIngest.genRandomValue(rval, 2, row, col);
if (entry.getValue().compareTo(rval) != 0) {
- throw new Exception("unexcepted value row=" + row + " col=" + col);
+ throw new Exception("unexpected value row=" + row + " col=" + col);
}
}
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/PermissionsIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/PermissionsIT.java
index 02a0149..865e7bb 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/PermissionsIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/PermissionsIT.java
@@ -298,7 +298,7 @@ public class PermissionsIT extends AccumuloClusterHarness {
loginAs(testUser);
test_user_client.instanceOperations()
.removeProperty(Property.TSERV_TOTAL_MUTATION_QUEUE_MAX.getKey());
- throw new IllegalStateException("Should NOT be able to remove Sysem
Property");
+ throw new IllegalStateException("Should NOT be able to remove System
Property");
} catch (AccumuloSecurityException e) {
loginAs(rootUser);
if (e.getSecurityErrorCode() != SecurityErrorCode.PERMISSION_DENIED
@@ -731,7 +731,7 @@ public class PermissionsIT extends AccumuloClusterHarness {
try {
test_user_client.tableOperations().flush(tableName, new
Text("myrow"), new Text("myrow~"),
false);
- throw new IllegalStateException("Should NOT be able to flsuh a
table");
+ throw new IllegalStateException("Should NOT be able to flush a
table");
} catch (AccumuloSecurityException e) {
if (e.getSecurityErrorCode() != SecurityErrorCode.PERMISSION_DENIED)
throw e;
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/ScanIteratorIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/ScanIteratorIT.java
index 519c7a5..fee1e49 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/ScanIteratorIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/ScanIteratorIT.java
@@ -173,7 +173,7 @@ public class ScanIteratorIT extends AccumuloClusterHarness {
int expected = start;
for (Entry<Key,Value> entry : scanner) {
if (Integer.parseInt(entry.getKey().getRow().toString()) != expected) {
- throw new Exception("Saw unexpexted " + entry.getKey().getRow() + " "
+ expected);
+ throw new Exception("Saw unexpected " + entry.getKey().getRow() + " "
+ expected);
}
if (entry.getKey().getColumnQualifier().toString().equals("cq2")) {
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/SummaryIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/SummaryIT.java
index 6ec4e45..0146db9 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/SummaryIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/SummaryIT.java
@@ -644,7 +644,7 @@ public class SummaryIT extends SharedMiniClusterBase {
try (AccumuloClient c2 =
Accumulo.newClient().from(c.properties()).as("user1",
passTok).build()) {
var e = assertThrows(
- "Expected operation to fail because user does not have permssion
to get summaries",
+ "Expected operation to fail because user does not have permission
to get summaries",
AccumuloSecurityException.class,
() -> c2.tableOperations().summaries(table).retrieve());
assertEquals(SecurityErrorCode.PERMISSION_DENIED,
e.getSecurityErrorCode());
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/YieldingIterator.java
b/test/src/main/java/org/apache/accumulo/test/functional/YieldingIterator.java
index 0e1d2bc..ad3f2ca 100644
---
a/test/src/main/java/org/apache/accumulo/test/functional/YieldingIterator.java
+++
b/test/src/main/java/org/apache/accumulo/test/functional/YieldingIterator.java
@@ -107,7 +107,7 @@ public class YieldingIterator extends WrappingIterator {
if (range.isStartKeyInclusive()) {
// must be a new scan so re-initialize the counters
- log.info("reseting counters");
+ log.info("resetting counters");
resetCounters();
} else {
rebuilds.incrementAndGet();
diff --git
a/test/src/main/java/org/apache/accumulo/test/replication/ReplicationOperationsImplIT.java
b/test/src/main/java/org/apache/accumulo/test/replication/ReplicationOperationsImplIT.java
index 96e2823..750d582 100644
---
a/test/src/main/java/org/apache/accumulo/test/replication/ReplicationOperationsImplIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/replication/ReplicationOperationsImplIT.java
@@ -205,7 +205,7 @@ public class ReplicationOperationsImplIT extends
ConfigurableMacBase {
// After both metadata and replication
assertTrue("Drain never finished", done.get());
- assertFalse("Saw unexpectetd exception", exception.get());
+ assertFalse("Saw unexpected exception", exception.get());
}
@Test
