Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

update some wrong spell #326

Merged
merged 1 commit into from
Jul 22, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -139,8 +139,8 @@ private void reconnectIfDisconnected() {

}

private static class SaslMetastoreClientHander implements InvocationHandler {
private static final Logger LOG = LoggerFactory.getLogger(SaslMetastoreClientHander.class);
private static class SaslMetastoreClientHandler implements InvocationHandler {
private static final Logger LOG = LoggerFactory.getLogger(SaslMetastoreClientHandler.class);

private final CloseableThriftHiveMetastoreIface baseHandler;
private final ThriftMetastoreClientManager clientManager;
Expand All @@ -151,11 +151,11 @@ private static class SaslMetastoreClientHander implements InvocationHandler {
public static CloseableThriftHiveMetastoreIface newProxyInstance(
CloseableThriftHiveMetastoreIface baseHandler,
ThriftMetastoreClientManager clientManager) {
return (CloseableThriftHiveMetastoreIface) Proxy.newProxyInstance(SaslMetastoreClientHander.class.getClassLoader(),
INTERFACES, new SaslMetastoreClientHander(baseHandler, clientManager));
return (CloseableThriftHiveMetastoreIface) Proxy.newProxyInstance(SaslMetastoreClientHandler.class.getClassLoader(),
INTERFACES, new SaslMetastoreClientHandler(baseHandler, clientManager));
}

private SaslMetastoreClientHander(
private SaslMetastoreClientHandler(
CloseableThriftHiveMetastoreIface handler,
ThriftMetastoreClientManager clientManager) {
this.baseHandler = handler;
Expand Down Expand Up @@ -233,8 +233,8 @@ CloseableThriftHiveMetastoreIface newInstance(
if (base.isSaslEnabled()) {
CloseableThriftHiveMetastoreIface ifaceReconnectingHandler = (CloseableThriftHiveMetastoreIface) Proxy
.newProxyInstance(getClass().getClassLoader(), INTERFACES, reconnectingHandler);
// wrapping the SaslMetastoreClientHander to handle delegation token if using sasl
return SaslMetastoreClientHander.newProxyInstance(ifaceReconnectingHandler, base);
// wrapping the SaslMetastoreClientHandler to handle delegation token if using sasl
return SaslMetastoreClientHandler.newProxyInstance(ifaceReconnectingHandler, base);
} else {
return (CloseableThriftHiveMetastoreIface) Proxy
.newProxyInstance(getClass().getClassLoader(), INTERFACES, reconnectingHandler);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ private void startWaggleDance(
throws Throwable {
try {
// Server will create new threads up to max as necessary. After an idle
// period, it will destory threads to keep the number of threads in the
// period, it will destroy threads to keep the number of threads in the
// pool to min.
int minWorkerThreads = hiveConf.getIntVar(ConfVars.METASTORESERVERMINTHREADS);
int maxWorkerThreads = hiveConf.getIntVar(ConfVars.METASTORESERVERMAXTHREADS);
Expand Down Expand Up @@ -285,7 +285,7 @@ private void signalOtherThreadsToStart(
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
LOG.warn("Signalling thread was interuppted: " + e.getMessage());
LOG.warn("Signalling thread was interrupted: " + e.getMessage());
}
} while (!server.isServing());
startLock.lock();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public AccessControlHandler newInstance(AbstractMetaStore metaStore) {
}

default:
throw new IllegalStateException("Cannot determine AcccessControlHandler type given type: '"
throw new IllegalStateException("Cannot determine AccessControlHandler type given type: '"
+ metaStore.getAccessControlType()
+ "'");
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import com.hotels.bdp.waggledance.extensions.client.ratelimit.BucketService;

/**
* This class uses a Redis server as a the storage back-end for the rate limiter. This is useful if you have multiple
* This class uses a Redis server as the storage back-end for the rate limiter. This is useful if you have multiple
* Waggle Dance instances and you want to rate limit across all of them.
*/
public class RedisBucketService implements BucketService {
Expand Down
Loading