Permalink
Browse files

Merge pull request #3 from d2r/derekd-remove-extra-Integer

Remove extra Integer ctor call
  • Loading branch information...
2 parents 2a78dc0 + 010ca82 commit af2c7937ec965b101b5511f453c909500a635ee4 @anfeng anfeng committed Feb 28, 2013
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/jvm/backtype/storm/utils/NimbusClient.java
View
4 src/jvm/backtype/storm/utils/NimbusClient.java
@@ -8,15 +8,15 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class NimbusClient extends ThriftClient {
+public class NimbusClient extends ThriftClient {
private Nimbus.Client _client;
private static final Logger LOG = LoggerFactory.getLogger(NimbusClient.class);
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 = new Integer(Utils.getInt(conf.get(Config.NIMBUS_TASK_TIMEOUT_SECS)));
+ Integer timeout = Utils.getInt(conf.get(Config.NIMBUS_TASK_TIMEOUT_SECS));
return new NimbusClient(conf, nimbusHost, nimbusPort, timeout);
} catch (TTransportException ex) {
LOG.info(ex.getMessage(), ex);

0 comments on commit af2c793

Please sign in to comment.