Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.3.2
-
None
-
The error message is the SAME whether the right path or not for a python job, as below:
[root@master bin]# ./pyflink.sh /home/al/flink/examples/python/WordCount.py
Cluster configuration: Standalone cluster with JobManager at localhost/https://www.linkedin.com/redir/invalid-link-page?url=127%2e0%2e0%2e1%3A6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Usage: ./bin/pyflink<2/3>.[sh/bat] <pathToScript>[ <pathToPackage1>[ <pathToPackageX]][ - <parameter1>[ <parameterX>]]The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.
[root@master bin]# ./pyflink.sh /home/al/flink/examples/python/WordCount.pys
Cluster configuration: Standalone cluster with JobManager at localhost/https://www.linkedin.com/redir/invalid-link-page?url=127%2e0%2e0%2e1%3A6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Usage: ./bin/pyflink<2/3>.[sh/bat] <pathToScript>[ <pathToPackage1>[ <pathToPackageX]][ - <parameter1>[ <parameterX>]]The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.
The first link is correct and was tested. The second is a fake. Still, the error is the SAME. Bug?
The error message is the SAME whether the right path or not for a python job, as below: [root@master bin] # ./pyflink.sh /home/al/flink/examples/python/WordCount.py Cluster configuration: Standalone cluster with JobManager at localhost/ https://www.linkedin.com/redir/invalid-link-page?url=127%2e0%2e0%2e1%3A6123 Using address localhost:6123 to connect to JobManager. JobManager web interface address http://localhost:8081 Starting execution of program Usage: ./bin/pyflink<2/3>. [sh/bat] <pathToScript>[ <pathToPackage1>[ <pathToPackageX]][ - <parameter1>[ <parameterX>]] The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment. [root@master bin] # ./pyflink.sh /home/al/flink/examples/python/WordCount.pys Cluster configuration: Standalone cluster with JobManager at localhost/ https://www.linkedin.com/redir/invalid-link-page?url=127%2e0%2e0%2e1%3A6123 Using address localhost:6123 to connect to JobManager. JobManager web interface address http://localhost:8081 Starting execution of program Usage: ./bin/pyflink<2/3>. [sh/bat] <pathToScript>[ <pathToPackage1>[ <pathToPackageX]][ - <parameter1>[ <parameterX>]] The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment. The first link is correct and was tested. The second is a fake. Still, the error is the SAME. Bug?
Attachments
Issue Links
- is duplicated by
-
FLINK-8109 PythonPlanBinder should check for script existence
- Closed