[incubator-seatunnel] branch cdc-multiple-table updated: [Improve] Improve Common And AbstractPluginDiscovery (#4133)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch cdc-multiple-table
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/cdc-multiple-table by this 
push:
     new 78b9a739c [Improve] Improve Common And AbstractPluginDiscovery (#4133)
78b9a739c is described below

commit 78b9a739cfc5d21cbd04ba68a31b115e5a2ec843
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Wed Feb 15 12:03:17 2023 +0800

    [Improve] Improve Common And AbstractPluginDiscovery (#4133)
---
 .../src/main/java/org/apache/seatunnel/common/config/Common.java   | 7 ++++++-
 .../apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java | 4 ++++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java 
b/seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java
index 8f417cd17..7773d7562 100644
--- 
a/seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java
+++ 
b/seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java
@@ -100,7 +100,12 @@ public class Common {
      * Plugin Root Dir
      */
     public static Path pluginRootDir() {
-        return Paths.get(appRootDir().toString(), "plugins");
+        String seatunnelHome = System.getProperty("SEATUNNEL_HOME");
+        if (StringUtils.isBlank(seatunnelHome)) {
+            return Paths.get(appRootDir().toString(), "plugins");
+        } else {
+            return Paths.get(seatunnelHome, "plugins");
+        }
     }
 
     /**
diff --git 
a/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
 
b/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
index c10569a81..5cefd2bdc 100644
--- 
a/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
+++ 
b/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
@@ -153,6 +153,10 @@ public abstract class AbstractPluginDiscovery<T> 
implements PluginDiscovery<T> {
         return pluginIdentifiers;
     }
 
+    public Path getPluginDir() {
+        return pluginDir;
+    }
+
     @Override
     public T createPluginInstance(PluginIdentifier pluginIdentifier) {
         return (T) createPluginInstance(pluginIdentifier, 
Collections.EMPTY_LIST);