[incubator-paimon] branch master updated: [hotfix]PluginLoader should use yarn tmp directory for yarn cluster (#938)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 3701d3ab3 [hotfix]PluginLoader should use yarn tmp directory for yarn 
cluster (#938)
3701d3ab3 is described below

commit 3701d3ab3a81e3942152b0db9d399a5643e50231
Author: Daixinyu <daixia...@users.noreply.github.com>
AuthorDate: Tue Apr 18 19:19:04 2023 +0800

    [hotfix]PluginLoader should use yarn tmp directory for yarn cluster (#938)
---
 .../src/main/java/org/apache/paimon/plugin/PluginLoader.java        | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/paimon-common/src/main/java/org/apache/paimon/plugin/PluginLoader.java 
b/paimon-common/src/main/java/org/apache/paimon/plugin/PluginLoader.java
index ea1bfc62b..4de375e60 100644
--- a/paimon-common/src/main/java/org/apache/paimon/plugin/PluginLoader.java
+++ b/paimon-common/src/main/java/org/apache/paimon/plugin/PluginLoader.java
@@ -63,7 +63,11 @@ public class PluginLoader {
     public PluginLoader(String jarName) {
         try {
             ClassLoader ownerClassLoader = PluginLoader.class.getClassLoader();
-            Path tmpDirectory = 
Paths.get(System.getProperty("java.io.tmpdir"));
+            String localDirs = System.getenv("LOCAL_DIRS");
+            if (null == localDirs || "".equals(localDirs)) {
+                localDirs = System.getProperty("java.io.tmpdir");
+            }
+            Path tmpDirectory = Paths.get(localDirs);
             Files.createDirectories(
                     
LocalFileUtils.getTargetPathIfContainsSymbolicPath(tmpDirectory));
             Path delegateJar =