diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
index 1a47f2a84..e10b29bd5 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
@@ -57,6 +57,9 @@ public class ScanTask implements Runnable {
   private long minSleepTime;
   private long maxSleepTime;
 
+  private static final Map<String, String> SCAN_EXEC_HINTS =
+      Collections.singletonMap("scan_type", "fluo-ntfy");
+
   ScanTask(NotificationFinder finder, NotificationProcessor proccessor,
       PartitionManager partitionManager, Environment env, AtomicBoolean stopped, long minSleepTime,
       long maxSleepTime) {
@@ -191,6 +194,8 @@ private ScanCounts scan(Session session, PartitionInfo pi, Range range)
       NotificationHashFilter.setModulusParams(iterCfg, pi.getMyGroupSize(), pi.getMyIdInGroup());
       scanner.addScanIterator(iterCfg);
 
+      scanner.setExecutionHints(SCAN_EXEC_HINTS);
+
       ScanCounts counts = new ScanCounts();
 
       for (Entry<Key, Value> entry : scanner) {