docs: private void startProcessSelect() {
          executor.submit(new Runnable() {
  
              public void run() {
                  MDC.put(OtterConstants.splitPipelineLogFileKey, String.valueOf(pipelineId));
                  String currentName = Thread.currentThread().getName();
                  Thread.currentThread().setName(createTaskName(pipelineId, "ProcessSelect"));
                  try {
                      processSelect();
                  } finally {
                      Thread.currentThread().setName(currentName);
                      MDC.remove(OtterConstants.splitPipelineLogFileKey);
                  }
              }
          });
  
      }