Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-9241

Usage docs for ScalaGauge doesn't work

    XMLWordPrintableJSON

    Details

      Description

      In the docs, the example for using a gauge metric in scala doesn't even compile:

      [error] /vagrant/src/main/scala/net/juliobiason/pipeline/sideoutputs.scala:34: overloaded method value gauge with alternatives:
      [error]   [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: String, x$2: G)G <and>
      [error]   [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: Int, x$2: G)G
      [error]  cannot be applied to (String, org.apache.flink.api.scala.metrics.ScalaGauge[Int])
      [error]       .gauge("meanLateness", ScalaGauge[Int] ( () => meanLateness ))

        Attachments

          Activity

            People

            • Assignee:
              chesnay Chesnay Schepler
              Reporter:
              JBiason Julio Biason
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: