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

Commit 69aeeef

Browse files
committed
fix: lint
Change-Id: I78712b99a975fb6ec9defcdb6812e955df555e1f
1 parent 98fe29b commit 69aeeef

2 files changed

Lines changed: 8 additions & 6 deletions

File tree

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,9 @@ public ChannelPoolHealthChecker(
100100

101101
void start() {
102102
if (!(channelPrimer instanceof BigtableChannelPrimer)) {
103-
logger.log(Level.WARNING, "Provided channelPrimer not an instance of BigtableChannelPrimer, not checking channel health.");
103+
logger.log(
104+
Level.WARNING,
105+
"Provided channelPrimer not an instance of BigtableChannelPrimer, not checking channel health.");
104106
} else {
105107
Duration initialDelayProbe =
106108
Duration.ofMillis(ThreadLocalRandom.current().nextLong(PROBE_INTERVAL.toMillis()));
@@ -134,7 +136,10 @@ public void stop() {
134136
/** Runs probes on all the channels in the pool. */
135137
@VisibleForTesting
136138
void runProbes() {
137-
Preconditions.checkState(channelPrimer instanceof BigtableChannelPrimer, "Health checking can only be enabled with BigtableChannelPrimer, found %s", channelPrimer);
139+
Preconditions.checkState(
140+
channelPrimer instanceof BigtableChannelPrimer,
141+
"Health checking can only be enabled with BigtableChannelPrimer, found %s",
142+
channelPrimer);
138143
for (Entry entry : this.entrySupplier.get()) {
139144
final Instant startTime = clock.instant();
140145
final ApiFuture<PingAndWarmResponse> probeFuture;

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/BigtableDataClientFactoryTest.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import com.google.api.gax.rpc.WatchdogProvider;
2828
import com.google.bigtable.v2.BigtableGrpc;
2929
import com.google.bigtable.v2.FeatureFlags;
30-
import com.google.bigtable.v2.InstanceName;
3130
import com.google.bigtable.v2.MutateRowRequest;
3231
import com.google.bigtable.v2.MutateRowResponse;
3332
import com.google.bigtable.v2.PingAndWarmRequest;
@@ -52,8 +51,6 @@
5251
import java.io.IOException;
5352
import java.lang.reflect.Method;
5453
import java.net.SocketAddress;
55-
import java.util.LinkedList;
56-
import java.util.List;
5754
import java.util.concurrent.BlockingQueue;
5855
import java.util.concurrent.ConcurrentHashMap;
5956
import java.util.concurrent.ConcurrentMap;
@@ -263,7 +260,7 @@ public void testCreateForInstanceWithAppProfileHasCorrectSettings() throws Excep
263260
@Test
264261
public void testCreateWithRefreshingChannel() throws Exception {
265262
int poolSize = 3;
266-
BigtableDataSettings.Builder builder =
263+
BigtableDataSettings.Builder builder =
267264
BigtableDataSettings.newBuilderForEmulator(server.getPort())
268265
.setProjectId(DEFAULT_PROJECT_ID)
269266
.setInstanceId(DEFAULT_INSTANCE_ID)

0 commit comments

Comments
 (0)