@Override
    public void startQuery(Query query) {
      Object region = ((DefaultQuery) query).getRegionsInQuery(null).iterator().next();
      if (queryCount.incrementAndGet() == queryCountToDestroy) {
        PartitionedRegion partitionedRegion =
            (PartitionedRegion) PRQueryDUnitHelper.getCache().getRegion(PARTITIONED_REGION_NAME);
        List<Integer> localPrimaryBuckets = partitionedRegion.getLocalPrimaryBucketsListTestOnly();
        int bucketId = localPrimaryBuckets.get(0);
        partitionedRegion.getDataStore().getLocalBucketById(bucketId).destroyRegion();
      }
    }
1. Creates PR regions across with scope = DACK, 2 data-stores
<p>
2. Creates a Local region on one of the VM's
<p>
3. Puts in the same data both in PR region & the Local Region
<p>
4. Queries the data both in local & PR
<p>
5. Puts a QueryObservers in both local as well as remote data-store node, to throw some test
exceptions.
<p>
6. then re-executes the query on one of the data-store node.
<p>
7. Verifies the exception thrown is from local node not from remote node
<p>
geode-core/src/distributedTest/java/org/apache/geode/cache/query/partitioned/PRQueryRemoteNodeExceptionDUnitTest.java