private void loadParameters() {
    Map<String, String> paramMap = _heuristicConfData.getParamMap();
    String heuristicName = _heuristicConfData.getHeuristicName();

    String cacheLimit = paramMap.get(DISTRIBUTED_CACHE_FILE_SIZE_LIMIT_CONF);
    if (cacheLimit != null) {
      try {
        distributedCacheFileSizeLimit = Long.parseLong(cacheLimit);
        logger.info(
            heuristicName + " will use " + DISTRIBUTED_CACHE_FILE_SIZE_LIMIT_CONF + " with the following setting: "
                + distributedCacheFileSizeLimit);
      } catch (NumberFormatException e) {
        logger
            .warn("Error parsing " + DISTRIBUTED_CACHE_FILE_SIZE_LIMIT_CONF + " from the conf file. Check for typos...",
                e);
      }
    }
  }
Rule flags jobs which put files more than 500MB in the distributed cache.
app/com/linkedin/drelephant/mapreduce/heuristics/DistributedCacheLimitHeuristic.java