remove the use of NIMBUS_TASK_TIMEOUT_SECS from NimbusClient

jasonjckn · Mar 11, 2013 · 9956175 · 9956175
1 parent 61f08d6
commit 9956175
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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);
         }