[Feature][bootstrap] 通过system properties 获取config目录拓展的udf配置文件，待优化写入启动脚本start.sh

1 files changed, 4 insertions, 0 deletions

diff --git a/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/command/ExecuteCommand.java b/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/command/ExecuteCommand.java
index fbdf46f..e1f11d5 100644
--- a/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/command/ExecuteCommand.java
+++ b/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/command/ExecuteCommand.java
@@ -22,6 +22,8 @@ import java.util.Map;
 import java.util.Properties;
 
 import static com.geedgenetworks.bootstrap.utils.ConfigFileUtils.checkConfigExist;
+import static com.geedgenetworks.common.Constants.MAPPING_GROOTSTREAM_UDF;
+import static com.geedgenetworks.common.Constants.MAPPING_GROOTSTREAM_UDF_DEFAULT_PLUGIN;
 import static com.hazelcast.internal.config.DeclarativeConfigUtil.SYSPROP_MEMBER_CONFIG;
 
 @Slf4j
@@ -38,6 +40,8 @@ public class ExecuteCommand implements Command<ExecuteCommandArgs> {
         Properties properties = System.getProperties();
         properties.setProperty(Constants.SYSPROP_GROOTSTREAM_CONFIG, "config" + File.separator + Constants.HAZELCAST_GROOTSTREAM_DEFAULT_YAML);
         properties.setProperty(SYSPROP_MEMBER_CONFIG, "config" + File.separator + "hazelcast.yaml");
+        properties.setProperty(MAPPING_GROOTSTREAM_UDF, "config" + File.separator + MAPPING_GROOTSTREAM_UDF_DEFAULT_PLUGIN);
+
         GrootStreamConfig grootStreamConfig = ConfigProvider.locateAndGetGrootStreamConfig();
 
         Path configFile = ConfigFileUtils.getConfigPath(executeCommandArgs);