From 1383e48fece8a7b14d4079f718c5276bcf4897f4 Mon Sep 17 00:00:00 2001 From: panyy_f Date: Thu, 17 Oct 2024 16:04:35 +0800 Subject: [PATCH] fix: worker-agent cannot specify multiple server issues when registering with the server #1012 --- .../src/main/java/tech/powerjob/agent/MainApplication.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java b/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java index f1c8a184..ec1fc98d 100644 --- a/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java +++ b/powerjob-worker-agent/src/main/java/tech/powerjob/agent/MainApplication.java @@ -12,6 +12,9 @@ import picocli.CommandLine; import picocli.CommandLine.Command; import picocli.CommandLine.Option; +import java.util.ArrayList; +import java.util.List; + /** * powerjob-worker-agent entry * @@ -56,7 +59,8 @@ public class MainApplication implements Runnable { cfg.setAppName(appName); cfg.setPort(port); - cfg.setServerAddress(Splitter.on(",").splitToList(server)); + List servers = new ArrayList<>(Splitter.on(",").splitToList(server)); + cfg.setServerAddress(servers); cfg.setStoreStrategy(StoreStrategy.MEMORY.name().equals(storeStrategy) ? StoreStrategy.MEMORY : StoreStrategy.DISK); cfg.setMaxResultLength(length); cfg.setTag(tag);