diff --git a/docs/content.zh/docs/dev/table/sqlClient.md b/docs/content.zh/docs/dev/table/sqlClient.md index 7cb85bfa8df9a..e56215f248674 100644 --- a/docs/content.zh/docs/dev/table/sqlClient.md +++ b/docs/content.zh/docs/dev/table/sqlClient.md @@ -247,9 +247,9 @@ Mode "embedded" (default) submits Flink jobs from the local machine. (version >= 37.0.0). Please ensure that the specified environment meets the above requirements. - -pyfs,--pyFiles Attach custom python files for job. - The standard python resource file - suffixes such as .py/.egg/.zip or + -pyfs,--pyFiles Attach custom files for job. + The standard resource file suffixes + such as .py/.egg/.zip/.whl or directory are all supported. These files will be added to the PYTHONPATH of both the local client and the diff --git a/docs/content/docs/dev/table/sqlClient.md b/docs/content/docs/dev/table/sqlClient.md index 34ec1aa293474..279f6679c344f 100644 --- a/docs/content/docs/dev/table/sqlClient.md +++ b/docs/content/docs/dev/table/sqlClient.md @@ -253,9 +253,9 @@ Mode "embedded" (default) submits Flink jobs from the local machine. (version >= 37.0.0). Please ensure that the specified environment meets the above requirements. - -pyfs,--pyFiles Attach custom python files for job. - The standard python resource file - suffixes such as .py/.egg/.zip or + -pyfs,--pyFiles Attach custom files for job. + The standard resource file suffixes + such as .py/.egg/.zip/.whl or directory are all supported. These files will be added to the PYTHONPATH of both the local client and the diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java index 833443548ff4c..f86fa16de9afd 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java +++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java @@ -191,7 +191,7 @@ public class CliFrontendParser { "pyfs", "pyFiles", true, - "Attach custom python files for job. The standard python resource file suffixes such as .py/.egg/.zip or directory are all supported. " + "Attach custom files for job. The standard resource file suffixes such as .py/.egg/.zip/.whl or directory are all supported. " + "These files will be added to the PYTHONPATH of both the local client and the remote python UDF worker. " + "Files suffixed with .zip will be extracted and added to PYTHONPATH. " + "Comma (',') could be used as the separator to specify multiple files " diff --git a/flink-python/src/main/java/org/apache/flink/python/PythonOptions.java b/flink-python/src/main/java/org/apache/flink/python/PythonOptions.java index 098a6b658ad46..038191f84f4f7 100644 --- a/flink-python/src/main/java/org/apache/flink/python/PythonOptions.java +++ b/flink-python/src/main/java/org/apache/flink/python/PythonOptions.java @@ -70,7 +70,7 @@ public class PythonOptions { .stringType() .noDefaultValue() .withDescription( - "Attach custom python files for job. The standard python resource file suffixes such as .py/.egg/.zip or " + "Attach custom files for job. The standard resource file suffixes such as .py/.egg/.zip/.whl or " + "directory are all supported. These files will be added to the PYTHONPATH of both the local " + "client and the remote python UDF worker. Files suffixed with .zip will be extracted and added to PYTHONPATH. " + "Comma (',') could be used as the separator to specify multiple files. The option is equivalent to the command line option \"-pyfs\". ");