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

jincheng pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 078a69d  [hotfix][python] Fix the package name of PythonGatewayServer 
(#9351)
078a69d is described below

commit 078a69d232f47353b4c7728fc995b3bf8b97f820
Author: dianfu <fudian...@alibaba-inc.com>
AuthorDate: Sun Aug 4 14:05:49 2019 +0800

    [hotfix][python] Fix the package name of PythonGatewayServer (#9351)
---
 .../src/main/java/org/apache/flink/client/cli/ProgramOptions.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java 
b/flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java
index ca2ad1a..ff0114c 100644
--- 
a/flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java
+++ 
b/flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java
@@ -81,7 +81,7 @@ public abstract class ProgramOptions extends 
CommandLineOptions {
                        line.getOptionValue(CLASS_OPTION.getOpt()) : null;
 
                isPython = line.hasOption(PY_OPTION.getOpt()) | 
line.hasOption(PYMODULE_OPTION.getOpt())
-                       | 
"org.apache.flink.python.client.PythonGatewayServer".equals(entryPointClass);
+                       | 
"org.apache.flink.client.python.PythonGatewayServer".equals(entryPointClass);
                // If specified the option -py(--python)
                if (line.hasOption(PY_OPTION.getOpt())) {
                        // Cannot use option -py and -pym simultaneously.

Reply via email to