typo
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/a545ae72 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/a545ae72 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/a545ae72 Branch: refs/heads/0.2-dev Commit: a545ae729a3c4393472f70c497bc5a03df1cb1d0 Parents: e2fe47a Author: twilliams <[email protected]> Authored: Sat Feb 2 21:01:50 2013 -0500 Committer: twilliams <[email protected]> Committed: Sat Feb 2 21:01:50 2013 -0500 ---------------------------------------------------------------------- .../apache/blur/thrift/AbstractThriftServer.java | 8 ++++---- 1 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a545ae72/src/blur-core/src/main/java/org/apache/blur/thrift/AbstractThriftServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/thrift/AbstractThriftServer.java b/src/blur-core/src/main/java/org/apache/blur/thrift/AbstractThriftServer.java index da1775e..69a5e1e 100644 --- a/src/blur-core/src/main/java/org/apache/blur/thrift/AbstractThriftServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/thrift/AbstractThriftServer.java @@ -50,7 +50,7 @@ public abstract class AbstractThriftServer { private String _bindAddress; private BlurShutdown _shutdown; private ExecutorService _executorService; - private ExecutorService _queryExexutorService; + private ExecutorService _queryExecutorService; private ExecutorService _mutateExecutorService; private TBaseProcessor<?> _processor; @@ -60,7 +60,7 @@ public abstract class AbstractThriftServer { _shutdown.shutdown(); _server.stop(); _executorService.shutdownNow(); - _queryExexutorService.shutdownNow(); + _queryExecutorService.shutdownNow(); _mutateExecutorService.shutdownNow(); } } @@ -88,8 +88,8 @@ public abstract class AbstractThriftServer { _mutateExecutorService = Executors.newThreadPool("thrift-processors-mutate", _threadCount); methodCallsToExecutorService.put("mutate", _mutateExecutorService); methodCallsToExecutorService.put("mutateBatch", _mutateExecutorService); - _queryExexutorService = Executors.newThreadPool("thrift-processors-query", _threadCount); - methodCallsToExecutorService.put("query", _queryExexutorService); + _queryExecutorService = Executors.newThreadPool("thrift-processors-query", _threadCount); + methodCallsToExecutorService.put("query", _queryExecutorService); args.setMethodCallsToExecutorService(methodCallsToExecutorService); _server = new ExecutorServicePerMethodCallThriftServer(args); LOG.info("Starting server [{0}]", _nodeName);
