This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e8e9db37e17110ff04175d2720484b34f5c4d5ba Author: Weijie Guo <[email protected]> AuthorDate: Tue Oct 25 11:54:56 2022 +0800 [FLINK-29728] TablePlanner prevents Flink from starting is working directory is a symbolic link This closes #21125 --- .../main/java/org/apache/flink/table/planner/loader/PlannerModule.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java b/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java index 7968abd4723..bba6c76c740 100644 --- a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java +++ b/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java @@ -27,6 +27,7 @@ import org.apache.flink.table.api.TableException; import org.apache.flink.table.delegation.ExecutorFactory; import org.apache.flink.table.delegation.PlannerFactory; import org.apache.flink.table.factories.FactoryUtil; +import org.apache.flink.util.FileUtils; import org.apache.flink.util.IOUtils; import java.io.IOException; @@ -93,7 +94,7 @@ class PlannerModule { final Path tmpDirectory = Paths.get(ConfigurationUtils.parseTempDirectories(new Configuration())[0]); - Files.createDirectories(tmpDirectory); + Files.createDirectories(FileUtils.getTargetPathIfContainsSymbolicPath(tmpDirectory)); final Path tempFile = Files.createFile( tmpDirectory.resolve(
