docs: private void init(Configuration cfg) throws IOException {
          Settings settings = HadoopSettingsManager.loadFrom(cfg);
          Assert.hasText(settings.getResourceWrite(), String.format("No resource ['%s'] (index/query/location) specified", ES_RESOURCE));
  
          // Need to discover the ESVersion before checking if index exists.
          InitializationUtils.discoverClusterInfo(settings, log);
          InitializationUtils.checkIdForOperation(settings);
          InitializationUtils.checkIndexExistence(settings);
  
          if (HadoopCfgUtils.getReduceTasks(cfg) != null) {
              if (HadoopCfgUtils.getSpeculativeReduce(cfg)) {
                  log.warn("Speculative execution enabled for reducer - consider disabling it to prevent data corruption");
              }
          }
          else {
              if (HadoopCfgUtils.getSpeculativeMap(cfg)) {
                  log.warn("Speculative execution enabled for mapper - consider disabling it to prevent data corruption");
              }
          }
  
          //log.info(String.format("Starting to write/index to [%s][%s]", settings.getTargetUri(), settings.getTargetResource()));
      }