[improve][common][core]修改udf注册文件读取方式，与配置文件读取方式相同，修改配置文件名

1 files changed, 1 insertions, 0 deletions

diff --git a/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/execution/JobRuntimeEnvironment.java b/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/execution/JobRuntimeEnvironment.java
index 9db4d11..2090243 100644
--- a/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/execution/JobRuntimeEnvironment.java
+++ b/groot-bootstrap/src/main/java/com/geedgenetworks/bootstrap/execution/JobRuntimeEnvironment.java
@@ -113,6 +113,7 @@ public class JobRuntimeEnvironment implements RuntimeEnvironment{
         } else {
             environment = StreamExecutionEnvironment.getExecutionEnvironment(configuration);
         }
+        configuration.setString(Constants.MAPPING_GROOTSTREAM_UDF, JSON.toJSONString(grootStreamConfig.getUdfMappingConfig()));
         configuration.setString(Constants.SYSPROP_GROOTSTREAM_CONFIG, JSON.toJSONString(grootStreamConfig.getEngineConfig()));
         environment.getConfig().enableObjectReuse();
         environment.getConfig().setGlobalJobParameters(configuration);