[hotfix-52032][core] Fix load dirty-plugins throws error of "Trying to access closed classloader. Please check if you store classloaders directly or indirectly in static fields".

Author: tiezhu

Diff for: flinkx-core/src/main/java/com/dtstack/flinkx/util/DataSyncFactoryUtil.java

@@ -115,17 +115,11 @@ public static DirtyDataCollector discoverDirty(DirtyConf conf) {
         try {
             String pluginName = conf.getType();
             String pluginClassName = PluginUtil.getPluginClassName(pluginName, OperatorType.dirty);
-            Set<URL> urlList =
-                    PluginUtil.getJarFileDirPath(pluginName, conf.getLocalPluginPath(), null, "");
 
-            final DirtyDataCollector consumer =
-                    ClassLoaderManager.newInstance(
-                            urlList,
-                            cl -> {
-                                Class<?> clazz = cl.loadClass(pluginClassName);
-                                Constructor<?> constructor = clazz.getConstructor();
-                                return (DirtyDataCollector) constructor.newInstance();
-                            });
+            ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
+            Class<?> clazz = classLoader.loadClass(pluginClassName);
+            Constructor<?> constructor = clazz.getConstructor();
+            final DirtyDataCollector consumer = (DirtyDataCollector) constructor.newInstance();
             consumer.initializeConsumer(conf);
             return consumer;
         } catch (Exception e) {