Izeren commented on code in PR #26849:
URL: https://github.com/apache/flink/pull/26849#discussion_r2244833855
##########
docs/content.zh/docs/ops/metrics.md:
##########
@@ -465,6 +465,38 @@ counter = runtime_context
{{< /tab >}}
{{< /tabs >}}
+### Additional Variables for operators
+
+You can define custom variables that will be assigned to all metrics reported
by a given operator
+using `Transformation.addMetricVariable`. For example:
+
+{{< tabs "32c0ba7f-3acd-831f-4a8b-a2de81b0126e" >}}
+{{< tab "Java" >}}
+```java
+
+fooSource =
+ execEnv.fromSource(
+ kafkaSource,
+ getWatermarkStrategy(),
+ "KafkaSource-Foo")
+ .addMetricVariable("table_name", "Foo"");
Review Comment:
There is an extra quote After "Foo", same below after "Bar""
##########
docs/content.zh/docs/ops/metrics.md:
##########
@@ -465,6 +465,38 @@ counter = runtime_context
{{< /tab >}}
{{< /tabs >}}
+### Additional Variables for operators
+
+You can define custom variables that will be assigned to all metrics reported
by a given operator
+using `Transformation.addMetricVariable`. For example:
+
+{{< tabs "32c0ba7f-3acd-831f-4a8b-a2de81b0126e" >}}
Review Comment:
!nit you could probably use more descriptive tag name, but I see that it is
common to have uids in docs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
