diff --git a/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java b/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
index 416241dd..a2ff24e2 100644
--- a/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
+++ b/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
@@ -402,6 +402,7 @@ protected void doPickRelay(ConnectionState curState)
       {
         relayConn = _sourcesConn.getRelayConnFactory().createRelayConnection(
             serverInfo, this, _remoteExceptionHandler);
+        afterRelayChange();
         _log.info("picked a relay:" + serverInfo.toSimpleString());
       }
       catch (Exception e)
@@ -513,6 +514,11 @@ private String buildSubsList(List<DatabusSubscription> subs, Map<String, IdNameP
     sb.append("]");
     return sb.toString();
   }
+  
+  private void afterRelayChange()
+  {
+    _relayFilter = null;
+  }
 
   protected void doSourcesResponseSuccess(ConnectionState curState)
   {
@@ -1186,6 +1192,7 @@ private boolean onRelayFellOff(ConnectionState curState, Checkpoint cp, Throwabl
   @Override
   protected void tearConnection()
   {
+    afterRelayChange();
     _currentState.setRelayFellOff(false);
     super.tearConnection();
   }