@Before
  public void setUp() throws Exception {
    vm0 = getHost(0).getVM(0);
    vm1 = getHost(0).getVM(1);
    vm2 = getHost(0).getVM(2);

    redundancy = 0;
    numOfBuckets = 10;
    portfolio = createPortfolioData(CNT, CNT_DEST);
    prQueryDUnitHelper = new PRQueryDUnitHelper();
  }
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