@@ -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):
