update

eda/smart_rank/spark_streaming_monitor.py

@@ -16,7 +16,7 @@ while True:
         with open(log_path+"user_portrait_tag_name_increment_update_" + today + ".log", "a") as f:
             is_email = 0
             for batch in batchs_info:
-                if is_email == 0 and 'totalDelay' in batch and batch['totalDelay'] > 10000:
+                if is_email == 0 and 'totalDelay' in batch and batch['totalDelay'] > 2000:
                     batch_time = batch['batchTime']
                     GMT_FORMAT = '%Y-%m-%dT%H:%M:%S.000GMT'
                     batch_time_beijing = datetime.datetime.strptime(batch_time, GMT_FORMAT) + datetime.timedelta(hours=8)