fix

Pyspark_job/utils/templates.py

@@ -673,8 +673,6 @@ class Templates(object):
         print("当前任务id列表为： ", application_ids)
         if len(application_ids) == 1:
             print("实时消费正常开启！")
-            if self.test_flag == 'normal' and self.consumer_type == 'latest':
-                self.kafka_consumption_is_finished()
             self.read_data()
             self.modify_kafka_state()
             self.handle_data()