Try to fix python?

Signed-off-by: slinkydeveloper <francescoguard@gmail.com>
apache · Dec 16, 2021 · a35a17e · a35a17e
1 parent c74ef0a
commit a35a17e
Showing 1 changed file with 20 additions and 26 deletions.
diff --git a/flink-python/apache-flink-libraries/setup.py b/flink-python/apache-flink-libraries/setup.py
@@ -128,36 +128,30 @@ def find_file_path(pattern):
         VERSION_FILE_PATH = os.path.join(this_directory, "../pyflink/version.py")
         exist_licenses = os.path.exists(LICENSES_PATH)
 
+        PLANNER_SCALA_JAR_NAME = os.path.basename(
+            find_file_path(os.path.join(OPT_PATH, "flink-table-planner_*.jar")))
+        PLANNER_LOADER_JAR_NAME = os.path.basename(
+            find_file_path(os.path.join(LIB_PATH, "flink-table-planner-loader*.jar")))
+
         if not os.path.isdir(LIB_PATH):
             print(incorrect_invocation_message, file=sys.stderr)
             sys.exit(-1)
 
-        try:
-            os.symlink(LIB_PATH, LIB_TEMP_PATH)
-            support_symlinks = True
-        except BaseException:  # pylint: disable=broad-except
-            support_symlinks = False
-
-        os.mkdir(OPT_TEMP_PATH)
-        if support_symlinks:
-            os.symlink(os.path.join(OPT_PATH, OPT_PYTHON_JAR_NAME),
-                       os.path.join(OPT_TEMP_PATH, OPT_PYTHON_JAR_NAME))
-            os.symlink(os.path.join(OPT_PATH, OPT_SQL_CLIENT_JAR_NAME),
-                       os.path.join(OPT_TEMP_PATH, OPT_SQL_CLIENT_JAR_NAME))
-            os.symlink(PLUGINS_PATH, PLUGINS_TEMP_PATH)
-            os.symlink(LICENSE_FILE_PATH, LICENSE_FILE_TEMP_PATH)
-            os.symlink(README_FILE_PATH, README_FILE_TEMP_PATH)
-            os.symlink(VERSION_FILE_PATH, VERSION_FILE_TEMP_PATH)
-        else:
-            copytree(LIB_PATH, LIB_TEMP_PATH)
-            copy(os.path.join(OPT_PATH, OPT_PYTHON_JAR_NAME),
-                 os.path.join(OPT_TEMP_PATH, OPT_PYTHON_JAR_NAME))
-            copy(os.path.join(OPT_PATH, OPT_SQL_CLIENT_JAR_NAME),
-                 os.path.join(OPT_TEMP_PATH, OPT_SQL_CLIENT_JAR_NAME))
-            copytree(PLUGINS_PATH, PLUGINS_TEMP_PATH)
-            copy(LICENSE_FILE_PATH, LICENSE_FILE_TEMP_PATH)
-            copy(README_FILE_PATH, README_FILE_TEMP_PATH)
-            copy(VERSION_FILE_PATH, VERSION_FILE_TEMP_PATH)
+        copytree(LIB_PATH, LIB_TEMP_PATH)
+
+        # swap planner jar
+        os.remove(os.path.join(LIB_TEMP_PATH, PLANNER_LOADER_JAR_NAME))
+        copy(os.path.join(OPT_PATH, PLANNER_SCALA_JAR_NAME),
+             os.path.join(OPT_TEMP_PATH, PLANNER_SCALA_JAR_NAME))
+
+        copy(os.path.join(OPT_PATH, OPT_PYTHON_JAR_NAME),
+             os.path.join(OPT_TEMP_PATH, OPT_PYTHON_JAR_NAME))
+        copy(os.path.join(OPT_PATH, OPT_SQL_CLIENT_JAR_NAME),
+             os.path.join(OPT_TEMP_PATH, OPT_SQL_CLIENT_JAR_NAME))
+        copytree(PLUGINS_PATH, PLUGINS_TEMP_PATH)
+        copy(LICENSE_FILE_PATH, LICENSE_FILE_TEMP_PATH)
+        copy(README_FILE_PATH, README_FILE_TEMP_PATH)
+        copy(VERSION_FILE_PATH, VERSION_FILE_TEMP_PATH)
 
         os.mkdir(SCRIPTS_TEMP_PATH)
         bin_jars = glob.glob(os.path.join(SCRIPTS_PATH, "*.jar"))