diff --git a/omniadvisor/src/omniadvisor/service/spark_service/spark_cmd_parser.py b/omniadvisor/src/omniadvisor/service/spark_service/spark_cmd_parser.py index 2f865a2b13b01183aaf8f424434ef292dc458015..2e8b44d384ba739dd69cc66d8e3ba304b0558e3f 100644 --- a/omniadvisor/src/omniadvisor/service/spark_service/spark_cmd_parser.py +++ b/omniadvisor/src/omniadvisor/service/spark_service/spark_cmd_parser.py @@ -65,7 +65,8 @@ class SparkCMDParser: _parser.add_argument('--keytab') _parser.add_argument('--queue') _parser.add_argument('-d', '--database') - _parser.add_argument('-e', type=str, help='SQL statement to execute.') + # 支持对于--e这种形式的入参解析 但是--e为spark非官方用法 故在命令reconstruct的时候仍然使用-e的方式重建命令 + _parser.add_argument('-e', '--e', type=str, help='SQL statement to execute.') _parser.add_argument('-f', type=str, help='File containing SQL script.') _parser.add_argument('-i', help='Initialization SQL file') # boolean变量 diff --git a/omniadvisor/src/setup.py b/omniadvisor/src/setup.py index d23c92eb77bd7ff0f2a0b983462bb8edd155163b..18ae835f9d6decbaf18875ea1e022b33467dc516 100644 --- a/omniadvisor/src/setup.py +++ b/omniadvisor/src/setup.py @@ -29,7 +29,8 @@ def find_py_files(root): # 编译成 .pyc,并删除原 .py文件 py_path = os.path.join(dirpath, f) # 编译生成.pyc文件 - py_compile.compile(py_path, cfile=py_path + 'c') + py_compile.compile(py_path, cfile=py_path + 'c', + invalidation_mode=py_compile.PycInvalidationMode.CHECKED_HASH) # 删除原.py文件 os.remove(py_path) continue