@After
  public void tearDown() throws Exception {
    disconnectAllFromDS();
    invokeInEveryVM(() -> PRQueryDUnitHelper.setCache(null));
    invokeInEveryVM(QueryObserverHolder::reset);
  }
This test verifies exception handling on coordinator node for remote as well as local querying.
geode-core/src/distributedTest/java/org/apache/geode/cache/query/partitioned/PRQueryRemoteNodeExceptionDUnitTest.java