[BugFix] [PyFlink] Fix flink1.18 python options (DataLinkDC#3324)

aiwenmo · Mar 25, 2024 · deeeda8 · deeeda8
1 parent eed15b2
commit deeeda8
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/dinky-client/dinky-client-base/src/main/java/org/apache/flink/python/PythonOptions.java b/dinky-client/dinky-client-base/src/main/java/org/apache/flink/python/PythonOptions.java
@@ -110,6 +110,17 @@ public class PythonOptions {
                     + "optional parameter exists. The option is equivalent to the command line option "
                     + "\"-pyreq\".");
 
+    /** The configuration allows user to define python path for client and workers. */
+    public static final ConfigOption<String> PYTHON_PATH = ConfigOptions.key("python.pythonpath")
+            .stringType()
+            .noDefaultValue()
+            .withDescription(Description.builder()
+                    .text(
+                            "Specify the path on the Worker Node where the Flink Python Dependencies are installed, which "
+                                    + "gets added into the PYTHONPATH of the Python Worker."
+                                    + " The option is equivalent to the command line option \"-pypath\".")
+                    .build());
+
     public static final ConfigOption<String> PYTHON_ARCHIVES = ConfigOptions.key("python.archives")
             .stringType()
             .noDefaultValue()