fix

Pyspark_job/utils/templates.py

@@ -346,8 +346,7 @@ class Templates(object):
         try:
             self.start_process_instance()  # 开启海豚调度
             if self.query is not None:
-                self.query.awaitTermination()
-                self.query.stop()  # 退出实时消费
+                self.query.stop()  # 退出实时消费（移除awaitTermination避免线程冲突）
             if self.spark is not None:
                 self.spark.stop()
             exit(0) # 退出程序