code: @Override
      public Future<?> startPartition(PartitionPlanConfig partitionPlanConfig,
                                      Step step,
                                      PartitionReplyQueue partitionReplyQueue) {
          //This partition was dispatched remotely. Hence, param isRemoteDispatch should be true
          Entry<BatchPartitionWorkUnit, Future<?>> workUnitFutureEntry = batchKernelService.startPartition(partitionPlanConfig, step, partitionReplyQueue, true);
          return workUnitFutureEntry.getValue();
      }
docs: Start a partition sub-job. This method is called when the partition is being started
  on a remote executor via JMS (multi-jvm partitions).