PNDA-4545: Java Example application for Flink illustrating flink metrics

pndaproject · Jul 15, 2018 · c8755d3 · c8755d3
1 parent a68c1fa
commit c8755d3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/salt/flink/templates/flink.conf.tpl b/salt/flink/templates/flink.conf.tpl
@@ -229,10 +229,14 @@ historyserver.archive.fs.refresh-interval: 10000
 # Configure log directory path for PNDA flink
 env.log.dir: /var/log/pnda/flink
 python.dc.tmp.dir: {{ namenode }}/{{ python_tmp_dir }}/dc
+
 # Expose Metric to an external system (Graphite) by configuring the Reporter
 metrics.reporters: grph
 metrics.reporter.grph.class: org.apache.flink.metrics.graphite.GraphiteReporter
 metrics.reporter.grph.host: {{ graphite_node }}
 metrics.reporter.grph.port: {{ graphite_port }}
 metrics.reporter.grph.protocol: TCP
 metrics.reporter.grph.prefix: flink
+
+# Configure Metric reporting interval
+metrics.reporter.grph.interval: 60 SECONDS
diff --git a/salt/graphite-api/files/storage-schemas.conf.tpl b/salt/graphite-api/files/storage-schemas.conf.tpl
@@ -32,6 +32,10 @@ retentions = 60:43200
 pattern = ^spark\..*
 retentions = {{ retentions }}
 
+[flink]
+pattern = ^flink\..*
+retentions = 60:10080
+
 [default]
 pattern = .*
 retentions = 60:1440