|
|
@@ -8,7 +8,7 @@ from configs.settings import config
|
|
|
|
|
|
|
|
|
def spark_result_tb_name(job_id, task_id, spark_node_id, out_pin, is_tmp=False):
|
|
|
- return f'{config.get("HIVE","database_name")}.`job{job_id}_task{task_id}_subnode{spark_node_id}_output{out_pin}{"_tmp" if is_tmp else ""}`'
|
|
|
+ return f'{config.get("HIVE","database_name")}.job{job_id}_task{task_id}_subnode{spark_node_id}_output{out_pin}{"_tmp" if is_tmp else ""}'
|
|
|
|
|
|
|
|
|
def get_sub_task_script_uri(task_id, sub_node_id):
|
luoyulong