diff --git a/jstorm-core/src/main/java/backtype/storm/StormSubmitter.java b/jstorm-core/src/main/java/backtype/storm/StormSubmitter.java index f6ba8d9f1..5a920d443 100644 --- a/jstorm-core/src/main/java/backtype/storm/StormSubmitter.java +++ b/jstorm-core/src/main/java/backtype/storm/StormSubmitter.java @@ -204,7 +204,6 @@ public static boolean topologyNameExists(NimbusClient client, Map conf, String n private static String path = null; private static void submitJar(NimbusClient client, Map conf) { - String submittedJar = null; // if (submittedJar == null) { try { LOG.info("Jar not uploaded to master yet. Submitting jar..."); @@ -229,7 +228,7 @@ private static void submitJar(NimbusClient client, Map conf) { } if (localJar != null) { - submittedJar = submitJar(conf, localJar, uploadLocation, client); + submitJar(conf, localJar, uploadLocation, client); } else { // no client jar, but with lib jar client.getClient().finishFileUpload(uploadLocation);