diff --git a/adaptercore/device_handler.go b/adaptercore/device_handler.go
index 99d0d01..20eb783 100644
--- a/adaptercore/device_handler.go
+++ b/adaptercore/device_handler.go
@@ -795,8 +795,13 @@
 	log.Debugw("In UpdateFlowsIncrementally", log.Fields{"deviceId": device.Id, "flows": flows, "groups": groups})
 	if flows != nil {
 		for _, flow := range flows.ToAdd.Items {
+			log.Debug("Adding flow", log.Fields{"deviceId": device.Id, "flowToAdd": flow})
 			dh.flowMgr.AddFlow(flow)
 		}
+		for _, flow := range flows.ToRemove.Items {
+			log.Debug("Removing flow", log.Fields{"deviceId": device.Id, "flowToRemove": flow})
+			dh.flowMgr.RemoveFlow(flow)
+		}
 	}
 	if groups != nil {
 		for _, flow := range flows.ToRemove.Items {