File tree Expand file tree Collapse file tree 2 files changed +0
-12
lines changed
google-cloud-bigtable/src
main/java/com/google/cloud/bigtable/data/v2/stub
test/java/com/google/cloud/bigtable/data/v2 Expand file tree Collapse file tree 2 files changed +0
-12
lines changed Original file line number Diff line number Diff line change @@ -807,8 +807,6 @@ public EnhancedBigtableStubSettings build() {
807807 Preconditions .checkArgument (
808808 getTransportChannelProvider () instanceof InstantiatingGrpcChannelProvider ,
809809 "refreshingChannel only works with InstantiatingGrpcChannelProviders" );
810- Preconditions .checkArgument (
811- appProfileId != null , "refreshingChannel only works when appProfileId is set" );
812810 InstantiatingGrpcChannelProvider .Builder channelProviderBuilder =
813811 ((InstantiatingGrpcChannelProvider ) getTransportChannelProvider ()).toBuilder ();
814812 try {
Original file line number Diff line number Diff line change 4747import java .util .List ;
4848import java .util .concurrent .BlockingQueue ;
4949import java .util .concurrent .LinkedBlockingDeque ;
50- import java .util .concurrent .atomic .AtomicInteger ;
5150import org .junit .After ;
5251import org .junit .Before ;
5352import org .junit .Rule ;
@@ -80,7 +79,6 @@ public class BigtableDataClientFactoryTest {
8079 private int port ;
8180
8281 private final BlockingQueue <Attributes > attributes = new LinkedBlockingDeque <>();
83- private final AtomicInteger terminationCount = new AtomicInteger ();
8482
8583 @ Before
8684 public void setUp () throws IOException {
@@ -100,12 +98,6 @@ public Attributes transportReady(Attributes transportAttrs) {
10098 attributes .add (transportAttrs );
10199 return super .transportReady (transportAttrs );
102100 }
103-
104- @ Override
105- public void transportTerminated (Attributes transportAttrs ) {
106- terminationCount .incrementAndGet ();
107- super .transportTerminated (transportAttrs );
108- }
109101 })
110102 .build ();
111103
@@ -279,8 +271,6 @@ public void testCreateWithRefreshingChannel() throws Exception {
279271 }
280272 }
281273 assertThat (service .readRowsRequests ).containsExactly (expectedRequests .toArray ());
282- factory .close ();
283- assertThat (terminationCount .get ()).isEqualTo (poolSize );
284274 }
285275
286276 private static class FakeBigtableService extends BigtableGrpc .BigtableImplBase {
You can’t perform that action at this time.
0 commit comments