diff --git a/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java b/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
index 74c9b2cc27..e73a52ae09 100644
--- a/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
+++ b/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
@@ -201,23 +201,8 @@ protected void scanFileOrDirectory(final PollTableEntry entry, String fileURI) {
             log.debug("Polling: " + VFSUtils.maskURLPassword(fileURI));
         }
         if (entry.isClusterAware()) {
-            boolean leader = true;
-            ClusteringAgent agent = getConfigurationContext().getAxisConfiguration().getClusteringAgent();
-            log.warn("Although proxy is cluster aware, clustering config are not present, hence running the" +
-                         " the polling task in this node");
-            if (!leader) {
-                if (log.isDebugEnabled()) {
-                    log.debug("This Member is not the leader");
-                }
-                entry.setLastPollState(PollTableEntry.NONE);
-                long now = System.currentTimeMillis();
-                entry.setLastPollTime(now);
-                entry.setNextPollTime(now + entry.getPollInterval());
-                onPollCompletion(entry);
-                return;
-            }
             if (log.isDebugEnabled()) {
-                log.debug("This Member is the leader");
+                log.debug("Cluster aware flag is enabled.");
             }
         }
         FileSystemOptions fso = null;