Will-Lo commented on code in PR #3933:
URL: https://github.com/apache/gobblin/pull/3933#discussion_r1578184446
##########
gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java:
##########
@@ -42,18 +44,26 @@
* can replace the old metrics system with tighter integrations once it's
stable
*/
+@Slf4j
public class OpenTelemetryMetrics extends OpenTelemetryMetricsBase {
private static OpenTelemetryMetrics GLOBAL_INSTANCE;
private static final Long DEFAULT_OPENTELEMETRY_REPORTING_INTERVAL_MILLIS =
10000L;
+
private OpenTelemetryMetrics(State state) {
super(state);
}
@Override
protected MetricExporter initializeMetricExporter(State state) {
+
Preconditions.checkArgument(state.contains(ConfigurationKeys.METRICS_REPORTING_OPENTELEMETRY_ENDPOINT),
Review Comment:
Currently it's called by `KafkaJobStatusMonitorFactory` and it will loudly
fail during initialization if this field doesn't exist, good catch
--
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]
