File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
chunjun-core/src/main/java/com/dtstack/chunjun Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 2828import com .dtstack .chunjun .constants .ConstantValue ;
2929import com .dtstack .chunjun .dirty .DirtyConf ;
3030import com .dtstack .chunjun .dirty .utils .DirtyConfUtil ;
31+ import com .dtstack .chunjun .enums .ClusterMode ;
3132import com .dtstack .chunjun .enums .EJobType ;
3233import com .dtstack .chunjun .environment .EnvFactory ;
3334import com .dtstack .chunjun .environment .MyLocalStreamEnvironment ;
@@ -321,8 +322,13 @@ private static void configStreamExecutionEnvironment(
321322 factoryHelper .setPluginLoadMode (options .getPluginLoadMode ());
322323 factoryHelper .setEnv (env );
323324 factoryHelper .setExecutionMode (options .getMode ());
324-
325325 DirtyConf dirtyConf = DirtyConfUtil .parse (options );
326+ // 注册core包
327+ if (ClusterMode .local .name ().equalsIgnoreCase (options .getMode ())) {
328+ factoryHelper .registerCachedFile (
329+ "" , Thread .currentThread ().getContextClassLoader (), "" );
330+ }
331+
326332 factoryHelper .registerCachedFile (
327333 dirtyConf .getType (),
328334 Thread .currentThread ().getContextClassLoader (),
You can’t perform that action at this time.
0 commit comments