diff --git a/internal/pkg/core/device_handler.go b/internal/pkg/core/device_handler.go
index 74e1f30..6b7ca7e 100644
--- a/internal/pkg/core/device_handler.go
+++ b/internal/pkg/core/device_handler.go
@@ -532,6 +532,9 @@
 
 // doStateUp handle the olt up indication and update to voltha core
 func (dh *DeviceHandler) doStateUp(ctx context.Context) error {
+	//starting the stat collector
+	go startCollector(dh)
+
 	// Synchronous call to update device state - this method is run in its own go routine
 	if err := dh.coreProxy.DeviceStateUpdate(ctx, dh.device.Id, voltha.ConnectStatus_REACHABLE,
 		voltha.OperStatus_ACTIVE); err != nil {
@@ -744,8 +747,6 @@
 }
 
 func startCollector(dh *DeviceHandler) {
-	// Initial delay for OLT initialization
-	time.Sleep(1 * time.Minute)
 	logger.Debugf("Starting-Collector")
 	context := make(map[string]string)
 	for {
@@ -769,7 +770,6 @@
 				if val, ok := dh.activePorts.Load(i); ok && val == true {
 					cmpon := dh.portStats.collectPONMetrics(i)
 					logger.Debugf("Collect-PON-Metrics %v", cmpon)
-
 					go dh.portStats.publishMetrics("PONStats", cmpon, i, context, dh.deviceID)
 					logger.Debugf("Publish-PON-Metrics")
 				}
@@ -789,7 +789,6 @@
 		olterrors.NewErrAdapter("error-updating-performance-metrics", log.Fields{"device-id": device.Id}, err).LogAt(log.ErrorLevel)
 	}
 
-	go startCollector(dh)
 	go startHeartbeatCheck(ctx, dh)
 }
 
@@ -1400,6 +1399,9 @@
 	dh.discOnus = sync.Map{}
 	dh.onus = sync.Map{}
 
+	//stopping the stats collector
+	dh.stopCollector <- true
+
 	go dh.notifyChildDevices("unreachable")
 	cloned := proto.Clone(device).(*voltha.Device)
 	// Update the all pon ports state on that device to disable and NNI remains active as NNI remains active in openolt agent.