hxbks2ks opened a new pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472 ## What is the purpose of the change *This pull request adds support to submit Python Table API job in CliFrontend* ## Brief change log - *Add PythonDriver to start py4j GatewayServer and start a process that run python table program.* - *Add PythonUtil which is a util class have methods about preparing python env and starting python process.* - *Change CliFrontend checking job is a jarFile job to checking job is a Distinguished job(python or java)* - *Set the entrypoint "PythonDriver" in Clifrontend when the job is a python job* - *Add flink-table-*.jar to classpath in flink script when running flink script to submit a python job* - *Correct py4j relocation to py4j. in flink-dist.pom for avoiding filename py4j-src.zip transfered to a wrong file name org.apache.flink.api.python.py4j-src.zip* - *Add PY OPTION, PY_FILES , PY_MODULE OPTIONS in CliFrontendParser to support python job* - *Add FLINK_HOME=FLINK_ROOT_DIR because when running cli to start python job, the flink script will export FLINK_ROOT_DIR * - *Put java_import contents in a method in java_gateway.py because that method will be also be called in PythonDriver run python process which call table api* ## Verifying this change This change added tests and can be verified as follows: - *Add unit test in PythonDriverTest* - *Add unit test in PythonUtilTest* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (no) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (yes) - If yes, how is the feature documented? (docs)
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
