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

Long metric names cause Graphite to not store them

    XMLWordPrintableJSON

Details

    Description

      While using the GraphiteReporter and a simple job with a window function, I noticed that Flink generates metric names which are too long for Graphite to handle.

      githubCommits
                      .global()
                      .windowAll(TumblingEventTimeWindows.of(Time.days(1)))
                      .apply(new MyWindowFunction())
      

      The generated metric name was {{/opt/graphite/storage/whisper/172-20-3-229/taskmanager/flink-taskmanager-1-1/Commit-rate-per-day-program/TriggerWindow(TumblingEventTimeWindows(86400000),-ListStateDescriptor

      {name=window-contents,-defaultValue=null,-serializer=org-apache-flink-api-common-typeutils-base-ListSerializer@da6e90ca}

      ,EventTimeTrigger(),-AllWindowedStream-runJob(CommitRateProgram-java:96))->-Sink:-Unnamed/0/numRecordsInPerSecond/m1_rate.wsp}}

      The error only shows in the logs of Graphite.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              trohrmann Till Rohrmann
              Votes:
              1 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: