From 99561759320c5b296bdc318088e13fe77ba403b6 Mon Sep 17 00:00:00 2001 From: Nathan Marz Date: Mon, 11 Mar 2013 13:17:00 -0700 Subject: [PATCH] remove the use of NIMBUS_TASK_TIMEOUT_SECS from NimbusClient --- src/jvm/backtype/storm/utils/NimbusClient.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/jvm/backtype/storm/utils/NimbusClient.java b/src/jvm/backtype/storm/utils/NimbusClient.java index 7f86a5430..8869b9d61 100644 --- a/src/jvm/backtype/storm/utils/NimbusClient.java +++ b/src/jvm/backtype/storm/utils/NimbusClient.java @@ -16,8 +16,7 @@ public static NimbusClient getConfiguredClient(Map conf) { try { String nimbusHost = (String) conf.get(Config.NIMBUS_HOST); int nimbusPort = Utils.getInt(conf.get(Config.NIMBUS_THRIFT_PORT)); - Integer timeout = Utils.getInt(conf.get(Config.NIMBUS_TASK_TIMEOUT_SECS)); - return new NimbusClient(conf, nimbusHost, nimbusPort, timeout); + return new NimbusClient(conf, nimbusHost, nimbusPort); } catch (TTransportException ex) { throw new RuntimeException(ex); }