From 940a8ca5db99e5aacdab5af4b026fc23188c2e24 Mon Sep 17 00:00:00 2001 From: Mattie Fu Date: Fri, 13 Feb 2026 13:08:32 -0500 Subject: [PATCH] Bigtable: clean up client side metrics flag --- .../sdk/io/gcp/bigtable/BigtableServiceFactory.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceFactory.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceFactory.java index 9933204d6f6c..33b742d2db57 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceFactory.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceFactory.java @@ -51,9 +51,6 @@ class BigtableServiceFactory implements Serializable { private static final ConcurrentHashMap refCounts = new ConcurrentHashMap<>(); private static final Object lock = new Object(); - private static final String BIGTABLE_ENABLE_CLIENT_SIDE_METRICS = - "bigtable_enable_client_side_metrics"; - private static final String BIGTABLE_ENABLE_SKIP_LARGE_ROWS = "bigtable_enable_skip_large_rows"; @AutoValue @@ -130,11 +127,6 @@ BigtableServiceEntry getServiceForReading( BigtableConfigTranslator.translateReadToVeneerSettings( config, opts, optsFromBigtableOptions, pipelineOptions); - if (ExperimentalOptions.hasExperiment(pipelineOptions, BIGTABLE_ENABLE_CLIENT_SIDE_METRICS)) { - LOG.info("Enabling client side metrics"); - BigtableDataSettings.enableBuiltinMetrics(); - } - boolean skipLargeRows = ExperimentalOptions.hasExperiment(pipelineOptions, BIGTABLE_ENABLE_SKIP_LARGE_ROWS); @@ -181,11 +173,6 @@ BigtableServiceEntry getServiceForWriting( BigtableConfigTranslator.translateWriteToVeneerSettings( config, opts, optsFromBigtableOptions, pipelineOptions); - if (ExperimentalOptions.hasExperiment(pipelineOptions, BIGTABLE_ENABLE_CLIENT_SIDE_METRICS)) { - LOG.info("Enabling client side metrics"); - BigtableDataSettings.enableBuiltinMetrics(); - } - BigtableService service = new BigtableServiceImpl(settings); entry = BigtableServiceEntry.create(configId, service); entries.put(configId.id(), entry);