@Override
      public void run2() throws CacheException {
        QueryObserverHolder.reset();
      }
Test on PR on one server only using filter.
geode-core/src/distributedTest/java/org/apache/geode/cache/query/dunit/QueryUsingFunctionContextDUnitTest.java