@Override
  public void run() {
    try {
      innerRun();
    } catch (Exception e) {
      // Ignore all exceptions - because subsequent executions of this scheduled task will be suppressed
      // by the executor if the current task throws an unhandled exception.
      LOG.warn("Error while reporting metrics. Will retry in " + reportingInterval + " seconds.", e);
    }
  }
MetricsSnapshotReporter is a generic metrics reporter that sends metrics to a stream.

jobName // my-samza-job
jobId // an id that differentiates multiple executions of the same job
taskName // container_567890
host // eat1-app128.gird
version // 0.0.1
blacklist // Regex of metrics to ignore when flushing
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java