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

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

            Dates

              Created:
              Updated:
              Resolved: