From 685c54a822ad3cfefd6f57d22d7443c8105b9477 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=86=AF=E5=BC=80=E9=9C=9E00024505?= Date: Sat, 4 Feb 2017 16:12:29 +0800 Subject: [PATCH] fix : allow to submit more topos --- jstorm-core/src/main/java/backtype/storm/StormSubmitter.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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);