code: public void startPartitionWatch() throws InterruptedException, ExecutionException {
          Future<?> task = m_es.submit(new PartitionWatchEvent());
          task.get();
      }
docs: Initialized and start watching partition level cache, this function is blocking.
  @throws InterruptedException
  @throws ExecutionException