Enable BigQueryMetrics by default (#31015)

apache · Apr 30, 2024 · 4a134b5 · 4a134b5
1 parent 356311f
commit 4a134b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java b/...worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
@@ -612,7 +612,7 @@ public static void main(String[] args) throws Exception {
     MetricsEnvironment.setProcessWideContainer(new MetricsLogger(null));
 
     if (options.isEnableStreamingEngine()
-        && DataflowRunner.hasExperiment(options, "enable_per_worker_metrics")) {
+        && !DataflowRunner.hasExperiment(options, "disable_per_worker_metrics")) {
       enableBigQueryMetrics();
     }