fix : allow to submit more topos

alibaba · Feb 4, 2017 · 685c54a · 685c54a · longdafeng · Feb 7, 2017
1 parent 625f8a2
commit 685c54a
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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);