public static File getCsvLogDir(Map<String, Object> daemonConf) {
        String csvMetricsLogDirectory =
            ObjectReader.getString(daemonConf.get(DaemonConfig.STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR), null);
        if (csvMetricsLogDirectory == null) {
            csvMetricsLogDirectory = ConfigUtils.absoluteStormLocalDir(daemonConf);
            csvMetricsLogDirectory = csvMetricsLogDirectory + ConfigUtils.FILE_SEPARATOR + "csvmetrics";
        }
        File csvMetricsDir = new File(csvMetricsLogDirectory);
        validateCreateOutputDir(csvMetricsDir);
        return csvMetricsDir;
    }
@Test
    public void getCsvLogDir() {
        Map<String, Object> daemonConf = new HashMap<>();

        String currentPath = new File("").getAbsolutePath();
        daemonConf.put(Config.STORM_LOCAL_DIR, currentPath);
        File dir = new File(currentPath, "csvmetrics");
        assertEquals(dir, MetricsUtils.getCsvLogDir(daemonConf));

        daemonConf.put(DaemonConfig.STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR, "./");
        assertEquals(new File("./"), MetricsUtils.getCsvLogDir(daemonConf));
    }