fix

Pyspark_job/utils/templates.py

@@ -348,9 +348,6 @@ class Templates(object):
         def _do_stop():
             try:
                 if self.query is not None:
-                    # 先把调用时刻Kafka里已经存在但还没被消费的积压全部跑完，再停，
-                    # 避免爬虫刚标记完成、但还有一截尾巴数据没被下一次触发扫到就被stop掉
-                    self.query.processAllAvailable()
                     self.query.stop()  # 在子线程中调用，避免 foreachBatch 回调内死锁
                 if self.spark is not None:
                     self.spark.stop()