Flink Metrics Web UI don't show double value
How can I see double value in flink web ui on dashboard? Maybe, it's possible with something configuration?
When I tried see metrics, like Meter, on dashboard view only the integer part of number. In log I can see double value:
Function with metrics: https://github.com/dedkot01/busting-grain/blob/master/grain-generator/src/main/scala/org/dedkot/CounterProcessFunction.scala
File with Flink config: https://github.com/dedkot01/busting-grain/blob/master/local.conf
Full Cloudflow Sbt Project: https://github.com/dedkot01/busting-grain
If u want run project, just use command in project directory sbt pipeline/runLocal
If it's not possible in Flink Web UI, where it's possible? (maybe in Grafana?)
I'm not found answer how this fix in Flink Web UI.
It's good works in Prometheus and Grafana.
Screenshot from Grafana, value 0.2 is displayed correctly.
- Spark Send DataFrame as body of HTTP Post request
- Mix Lombok, Java and Scala in a maven project
- Best way to turn a List of Eithers into an Either of a List?
- Why scala compiler says that this type is used in non-specializable position?
- Understand how to use apply and unapply
- Scala fold function to detect occurrence of a value in Seq[String]
- How to generate Verilog rather than SystemVerilog from Chisel?
- How to specify indentations on multiline parameter lists in IntelliJ Scala?
- Scala GroupBy preserving insertion order?
- Scala - complex conditional pattern matching
- Difference between Array and List in scala
- What is the recommended way to setup integration test in sbt after the deprecation of custom configs
- Scala - List("a","b").map(fn) versus map(fn, List("a","b")
- Ideal Scala's compiler and libraries using Play framework
- Stream-Static Join: How to refresh (unpersist/persist) static Dataframe periodically
- How to make IntelliJ IDEA use javac for Java and scalac for Scala?
- What's the difference between == and .equals in Scala?
- Why AWS is rejecting my connections when I am using wholeTextFiles() with pyspark?
- How do I use a nightly build of Scala?
- Run only one package test cases scala
- Is `finally` block executed in case there is `return` inside a `try` or a `catch` block?
- What Scala version is used in maven Scala plugin by default?
- Difference between trait inheritance and self type annotation
- Scala: checking if an object is Numeric
- How to write spark streaming DF to Kafka topic
- Per EntityType Active Entity Limit in Cluster Sharding Passivation
- What are the Spark transformations that causes a Shuffle?
- Scala closures filename
- How to customize serialization of a key of a Map with jsoniter
- Scala 3: typed tuple zipping