Skip to content
This repository was archived by the owner on May 8, 2026. It is now read-only.

Commit 20ce707

Browse files
committed
fix
1 parent 70a3694 commit 20ce707

2 files changed

Lines changed: 1 addition & 10 deletions

File tree

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/ChannelPoolMetricsTracer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ public void registerLoadBalancingStrategy(String lbPolicy) {
8383

8484
/** Starts the periodic collection. */
8585
public ScheduledFuture<?> start(ScheduledExecutorService scheduler) {
86-
return scheduler.scheduleAtFixedRate(this, 0, SAMPLING_PERIOD_SECONDS, TimeUnit.SECONDS);
86+
return scheduler.scheduleAtFixedRate(this, SAMPLING_PERIOD_SECONDS, SAMPLING_PERIOD_SECONDS, TimeUnit.SECONDS);
8787
}
8888

8989
@Override

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableTransportChannelProvider.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@
4040
*/
4141
@InternalApi
4242
public final class BigtableTransportChannelProvider implements TransportChannelProvider {
43-
static final Logger LOG = Logger.getLogger(BigtableTransportChannelProvider.class.getName());
4443
private final InstantiatingGrpcChannelProvider delegate;
4544
private final ChannelPrimer channelPrimer;
4645
@Nullable private final ChannelPoolMetricsTracer channelPoolMetricsTracer;
@@ -170,14 +169,6 @@ public TransportChannel getTransportChannel() throws IOException {
170169
channelPoolMetricsTracer.registerChannelInsightsProvider(btChannelPool::getChannelInfos);
171170
channelPoolMetricsTracer.registerLoadBalancingStrategy(
172171
btPoolSettings.getLoadBalancingStrategy().name());
173-
if (backgroundExecutor != null) {
174-
channelPoolMetricsTracer.start(backgroundExecutor);
175-
} else {
176-
LOG.log(
177-
Level.WARNING,
178-
"backgroundExecutor is null, ChannelPoolMetricsTracer cannot be started.");
179-
}
180-
}
181172

182173
return GrpcTransportChannel.create(btChannelPool);
183174
}

0 commit comments

Comments
 (0)