diff --git a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DeviceFlowTable.java b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DeviceFlowTable.java
index 6bc5b5f..e60a552 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DeviceFlowTable.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DeviceFlowTable.java
@@ -688,6 +688,9 @@
             case TERM_ACTIVE:
                 activateTerm(event.subject());
                 break;
+            case TERM_UPDATE:
+                updateTerm(event.subject());
+                break;
             default:
                 break;
         }
@@ -724,6 +727,23 @@
     }
 
     /**
+     * Handles an update to a term.
+     */
+    private void updateTerm(DeviceReplicaInfo replicaInfo) {
+        if (replicaInfo.term() == this.replicaInfo.term()) {
+            this.replicaInfo = replicaInfo;
+
+            // If the local node is neither the master or a backup for the device *and the term is active*,
+            // clear the flow table.
+            if (activeTerm == replicaInfo.term()
+                && !replicaInfo.isMaster(localNodeId)
+                && !replicaInfo.isBackup(localNodeId)) {
+                flowBuckets.values().forEach(bucket -> bucket.clear());
+            }
+        }
+    }
+
+    /**
      * Sends a message to the given node wrapped in a Lamport timestamp.
      * <p>
      * Messages are sent in a {@link Timestamped} wrapper and are expected to be received in a {@link Timestamped}