Details
-
Bug
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
1.11.1
-
None
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
- is related to
-
FLINK-20388 Supports users setting operators' metrics name
- Open