diff --git a/core-cube/src/main/java/org/apache/kylin/cube/CubeDescManager.java b/core-cube/src/main/java/org/apache/kylin/cube/CubeDescManager.java
index f95ccf0a805..86827191d37 100644
--- a/core-cube/src/main/java/org/apache/kylin/cube/CubeDescManager.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/CubeDescManager.java
@@ -26,6 +26,7 @@
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.kylin.common.KylinConfig;
+import org.apache.kylin.common.persistence.JDBCResourceStore;
 import org.apache.kylin.common.persistence.JsonSerializer;
 import org.apache.kylin.common.persistence.ResourceStore;
 import org.apache.kylin.common.persistence.Serializer;
@@ -110,7 +111,10 @@ protected CubeDesc initEntityAfterReload(CubeDesc cubeDesc, String resourceName)
 
         // touch lower level metadata before registering my listener
         crud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new CubeDescSyncListener(), "cube_desc");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new CubeDescSyncListener(), "cube_desc");
+        }
     }
 
     private class CubeDescSyncListener extends Broadcaster.Listener {
diff --git a/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java b/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
index d24ecd480cc..846f8fa71e0 100755
--- a/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
@@ -34,6 +34,7 @@
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.kylin.common.KylinConfig;
+import org.apache.kylin.common.persistence.JDBCResourceStore;
 import org.apache.kylin.common.persistence.JsonSerializer;
 import org.apache.kylin.common.persistence.ResourceStore;
 import org.apache.kylin.common.persistence.Serializer;
@@ -138,7 +139,10 @@ protected CubeInstance initEntityAfterReload(CubeInstance cube, String resourceN
 
         // touch lower level metadata before registering my listener
         crud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new CubeSyncListener(), "cube");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new CubeSyncListener(), "cube");
+        }
     }
 
     private class CubeSyncListener extends Broadcaster.Listener {
diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/TableMetadataManager.java b/core-metadata/src/main/java/org/apache/kylin/metadata/TableMetadataManager.java
index 07b7f9aec6c..283392e1f31 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/TableMetadataManager.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/TableMetadataManager.java
@@ -28,6 +28,7 @@
 import java.util.Set;
 
 import org.apache.kylin.common.KylinConfig;
+import org.apache.kylin.common.persistence.JDBCResourceStore;
 import org.apache.kylin.common.persistence.JsonSerializer;
 import org.apache.kylin.common.persistence.RawResource;
 import org.apache.kylin.common.persistence.ResourceStore;
@@ -124,7 +125,10 @@ protected TableDesc initEntityAfterReload(TableDesc t, String resourceName) {
             }
         };
         srcTableCrud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new SrcTableSyncListener(), "table");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new SrcTableSyncListener(), "table");
+        }
     }
 
     private class SrcTableSyncListener extends Broadcaster.Listener {
@@ -305,7 +309,10 @@ protected TableExtDesc initEntityAfterReload(TableExtDesc t, String resourceName
             }
         };
         srcExtCrud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new SrcTableExtSyncListener(), "table_ext");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new SrcTableExtSyncListener(), "table_ext");
+        }
     }
 
     private class SrcTableExtSyncListener extends Broadcaster.Listener {
@@ -449,7 +456,10 @@ protected ExternalFilterDesc initEntityAfterReload(ExternalFilterDesc t, String
             }
         };
         extFilterCrud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new ExtFilterSyncListener(), "external_filter");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new ExtFilterSyncListener(), "external_filter");
+        }
     }
 
     private class ExtFilterSyncListener extends Broadcaster.Listener {
diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelManager.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelManager.java
index a8afb89ff90..8d757dfa7fd 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelManager.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelManager.java
@@ -24,6 +24,7 @@
 import java.util.Map;
 
 import org.apache.kylin.common.KylinConfig;
+import org.apache.kylin.common.persistence.JDBCResourceStore;
 import org.apache.kylin.common.persistence.ResourceStore;
 import org.apache.kylin.common.persistence.Serializer;
 import org.apache.kylin.common.persistence.WriteConflictException;
@@ -106,7 +107,10 @@ protected DataModelDesc initEntityAfterReload(DataModelDesc model, String resour
         // touch lower level metadata before registering model listener
         TableMetadataManager.getInstance(config);
         crud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new DataModelSyncListener(), "data_model");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new DataModelSyncListener(), "data_model");
+        }
     }
 
     private class DataModelSyncListener extends Broadcaster.Listener {
diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java b/core-metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java
index dcba9d89e0d..d462236b961 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java
@@ -30,6 +30,7 @@
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.kylin.common.KylinConfig;
+import org.apache.kylin.common.persistence.JDBCResourceStore;
 import org.apache.kylin.common.persistence.ResourceStore;
 import org.apache.kylin.common.util.AutoReadWriteLock;
 import org.apache.kylin.common.util.AutoReadWriteLock.AutoLock;
@@ -93,7 +94,10 @@ protected ProjectInstance initEntityAfterReload(ProjectInstance prj, String reso
 
         // touch lower level metadata before registering my listener
         crud.reloadAll();
-        Broadcaster.getInstance(config).registerListener(new ProjectSyncListener(), "project");
+
+        if (JDBCResourceStore.JDBC_SCHEME.equals(config.getMetadataUrl().getScheme())) {
+            Broadcaster.getInstance(config).registerListener(new ProjectSyncListener(), "project");
+        }
     }
 
     private class ProjectSyncListener extends Broadcaster.Listener {