fix

apache · Jan 10, 2025 · 882228e · 882228e
1 parent 30131a3
commit 882228e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/.../src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java b/.../src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java
@@ -257,14 +257,14 @@ private void callBrokerToExport(CommandLine commandLine, RPCHook rpcHook,
             } else if (inputBrokerAddr != null) {
                 futureList.add(sendRequest(type, defaultMQAdminExt, inputBrokerAddr, null));
             }
+            CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).whenComplete(
+                (v, t) -> System.out.print("broker export done.")
+            ).join();
         } catch (Exception e) {
             throw new RuntimeException(this.getClass().getSimpleName() + " command failed", e);
         } finally {
             defaultMQAdminExt.shutdown();
         }
-        CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).whenComplete(
-            (v, t) -> System.out.print("broker export done.")
-        ).join();
     }
 
     private CompletableFuture<Void> sendRequest(List<RocksDBConfigToJsonRequestHeader.ConfigType> type,