diff --git a/ArgusCore/src/main/java/com/salesforce/dva/argus/service/monitor/DataLagMonitor.java b/ArgusCore/src/main/java/com/salesforce/dva/argus/service/monitor/DataLagMonitor.java
index <HASH>..<HASH> 100644
--- a/ArgusCore/src/main/java/com/salesforce/dva/argus/service/monitor/DataLagMonitor.java
+++ b/ArgusCore/src/main/java/com/salesforce/dva/argus/service/monitor/DataLagMonitor.java
@@ -66,7 +66,10 @@ public class DataLagMonitor extends Thread{
 				Metric currMetric = metrics.get(0);
 				if(currMetric.getDatapoints()==null || currMetric.getDatapoints().size()==0) {
 					_logger.info("Data lag detected as data point list is empty");
-					isDataLagging=true;
+					if(!isDataLagging) {
+						isDataLagging=true;
+						sendDataLagEmailNotification();
+					}
 					continue;
 				}else {
 					long lastDataPointTime = 0L;
Made a change to send email notification in case of data lag