If no brokerUrl is specified use localhost (#274)

6ec05f94 · Sanjeev Kulkarni · Sijie Guo · 2e496461 · 6ec05f94
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java ...c/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java +3 -0

未找到文件。
--- a/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
+++ b/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -449,6 +449,9 @@ public class CmdFunctions extends CmdBase {
            if (brokerServiceUrl != null) {
                serviceUrl = brokerServiceUrl;
            }
+            if (serviceUrl == null) {
+                serviceUrl = "pulsar://localhost:6650";
+            }
            try (ProcessRuntimeFactory containerFactory = new ProcessRuntimeFactory(
                    serviceUrl, null, null, null)) {
                List<RuntimeSpawner> spawners = new LinkedList<>();