Updated Branches: refs/heads/0.1.5 e7e1a4067 -> 2876f5478
Print off ulimits. Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/f4b5ff34 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/f4b5ff34 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/f4b5ff34 Branch: refs/heads/0.1.5 Commit: f4b5ff34d68099d46b5afd86871d149467db89ec Parents: e7e1a40 Author: Aaron McCurry <[email protected]> Authored: Wed Mar 27 21:26:10 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Wed Mar 27 21:26:10 2013 -0400 ---------------------------------------------------------------------- .../blur/thrift/ThriftBlurControllerServer.java | 1 + .../apache/blur/thrift/ThriftBlurShardServer.java | 3 +- .../java/org/apache/blur/thrift/ThriftServer.java | 40 +++++++++++++- 3 files changed, 39 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f4b5ff34/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurControllerServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurControllerServer.java b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurControllerServer.java index 56289de..7e944b9 100644 --- a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurControllerServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurControllerServer.java @@ -66,6 +66,7 @@ public class ThriftBlurControllerServer extends ThriftServer { int serverIndex = getServerIndex(args); LOG.info("Setting up Controller Server"); BlurConfiguration configuration = new BlurConfiguration(); + printUlimits(); ThriftServer server = createServer(serverIndex, configuration); server.start(); } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f4b5ff34/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurShardServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurShardServer.java b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurShardServer.java index 29f4b72..0671234 100644 --- a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurShardServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftBlurShardServer.java @@ -75,10 +75,9 @@ public class ThriftBlurShardServer extends ThriftServer { public static void main(String[] args) throws Exception { int serverIndex = getServerIndex(args); LOG.info("Setting up Shard Server"); - Thread.setDefaultUncaughtExceptionHandler(new SimpleUncaughtExceptionHandler()); BlurConfiguration configuration = new BlurConfiguration(); - + printUlimits(); ThriftServer server = createServer(serverIndex, configuration); server.start(); } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f4b5ff34/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java index 30d54e9..ad1537b 100644 --- a/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/thrift/ThriftServer.java @@ -16,6 +16,10 @@ package org.apache.blur.thrift; * See the License for the specific language governing permissions and * limitations under the License. */ +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.UnknownHostException; @@ -35,7 +39,6 @@ import org.apache.thrift.server.TServer; import org.apache.thrift.transport.TNonblockingServerSocket; import org.apache.thrift.transport.TTransportException; - public class ThriftServer { private static final Log LOG = LogFactory.getLog(ThriftServer.class); @@ -53,6 +56,25 @@ public class ThriftServer { private ExecutorService _queryExexutorService; private ExecutorService _mutateExecutorService; + public static void printUlimits() throws IOException { + ProcessBuilder processBuilder = new ProcessBuilder("ulimit", "-a"); + Process process; + try { + process = processBuilder.start(); + } catch (Exception e) { + LOG.warn("Could not run ulimit command to retrieve limits.", e); + return; + } + + InputStream inputStream = process.getInputStream(); + BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream)); + String line; + while ((line = reader.readLine()) != null) { + LOG.info("ulimit: " + line); + } + reader.close(); + } + public synchronized void close() { if (!_closed) { _closed = true; @@ -126,14 +148,26 @@ public class ThriftServer { this._configuration = configuration; } - public static String getNodeName(BlurConfiguration configuration, String hostNameProperty) throws UnknownHostException { + public static String getNodeName(BlurConfiguration configuration, String hostNameProperty) + throws UnknownHostException { String hostName = configuration.get(hostNameProperty); if (hostName == null) { hostName = ""; } hostName = hostName.trim(); if (hostName.isEmpty()) { - return InetAddress.getLocalHost().getHostName(); + try { + return InetAddress.getLocalHost().getHostName(); + } catch (UnknownHostException e) { + String message = e.getMessage(); + int index = message.indexOf(':'); + if (index < 0) { + throw new RuntimeException("Nodename cannot be determined."); + } + String nodeName = message.substring(0, index); + LOG.warn("Hack to get nodename from exception [" + nodeName + "]"); + return nodeName; + } } return hostName; }
