You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/24 08:07:18 UTC
flink git commit: [FLINK-9241][metrics][docs] Fix ScalaGauge usage
example
Repository: flink
Updated Branches:
refs/heads/master fb254763c -> cdf4744ba
[FLINK-9241][metrics][docs] Fix ScalaGauge usage example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cdf4744b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cdf4744b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cdf4744b
Branch: refs/heads/master
Commit: cdf4744ba962aade9c6f4cda28b9a6d82448004f
Parents: fb25476
Author: zentol <ch...@apache.org>
Authored: Tue Apr 24 10:07:00 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Tue Apr 24 10:07:00 2018 +0200
----------------------------------------------------------------------
docs/monitoring/metrics.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/cdf4744b/docs/monitoring/metrics.md
----------------------------------------------------------------------
diff --git a/docs/monitoring/metrics.md b/docs/monitoring/metrics.md
index 1e70dd7..d0b98fb 100644
--- a/docs/monitoring/metrics.md
+++ b/docs/monitoring/metrics.md
@@ -182,7 +182,7 @@ new class MyMapper extends RichMapFunction[String,String] {
override def open(parameters: Configuration): Unit = {
getRuntimeContext()
.getMetricGroup()
- .gauge("MyGauge", ScalaGauge[Int]( () => valueToExpose ) )
+ .gauge[Int, ScalaGauge[Int]]("MyGauge", ScalaGauge[Int]( () => valueToExpose ) )
}
override def map(value: String): String = {