googleapis · igorbernstein2 · Nov 29, 2023 · Nov 28, 2023 · Nov 28, 2023 · Nov 28, 2023
@@ -129,7 +129,6 @@ limitations under the License.
       <plugin>
         <groupId>org.codehaus.mojo</groupId>
         <artifactId>build-helper-maven-plugin</artifactId>
-        <version>3.3.0</version>
         <executions>
           <execution>
             <id>add-source</id>

@@ -33,10 +33,6 @@ limitations under the License.
     Bigtable/HBase Mirroring Client conforming to HBase API 1.x. Uses hbase-client and shades all dependencies.
   </description>
 
-  <properties>
-    <!-- define a property that can be ignored by renovate -->
-    <hbase1-hadoop-slf4j.version>1.6.1</hbase1-hadoop-slf4j.version>
-  </properties>
 
   <dependencies>
     <!-- Internal dependencies that will be shaded along with their transitive dependencies. -->

diff --git a/...mirroring-client-1.x-parent/bigtable-hbase-mirroring-client-1.x-integration-tests/pom.xml b/...mirroring-client-1.x-parent/bigtable-hbase-mirroring-client-1.x-integration-tests/pom.xml
@@ -246,13 +246,6 @@ limitations under the License.
     </dependency>
 
     <!-- Misc -->
-    <dependency>
-      <groupId>com.google.protobuf</groupId>
-      <artifactId>protobuf-java</artifactId>
-      <version>3.22.2</version>
-      <scope>test</scope>
-    </dependency>
-
     <dependency>
       <groupId>commons-lang</groupId>
       <artifactId>commons-lang</artifactId>

@@ -33,11 +33,6 @@ limitations under the License.
     Bigtable/HBase Mirroring Client conforming to HBase API 2.x. Uses hbase-client and shades all dependencies.
   </description>
 
-  <properties>
-    <!-- define a property that can be ignored by renovate -->
-    <hbase2-hadoop-slf4j.version>1.7.30</hbase2-hadoop-slf4j.version>
-  </properties>
-
   <dependencies>
     <dependency>
       <groupId>com.google.cloud.bigtable</groupId>

@@ -73,13 +73,6 @@ limitations under the License.
       <scope>compile</scope>
     </dependency>
 
-    <dependency>
-      <groupId>org.checkerframework</groupId>
-      <artifactId>checker-compat-qual</artifactId>
-      <version>2.5.5</version>
-      <scope>provided</scope>
-    </dependency>
-
     <!-- deps to be shaded -->
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>

@@ -80,7 +80,6 @@
 import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message;
 import org.apache.hadoop.hbase.shaded.com.google.protobuf.Service;
 import org.apache.hadoop.hbase.util.Bytes;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * Table which mirrors every two mutations to two underlying tables.
@@ -96,7 +95,7 @@ public class MirroringTable implements Table {
   private static final Predicate<Object> resultIsFaultyPredicate =
       new Predicate<Object>() {
         @Override
-        public boolean apply(@NullableDecl Object o) {
+        public boolean apply(Object o) {
           return o == null || o instanceof Throwable;
         }
       };

@@ -16,7 +16,6 @@
 package com.google.cloud.bigtable.mirroring.core;
 
 import com.google.common.util.concurrent.FutureCallback;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * Write operations do not perform verification, only report failed writes. For this reason callback
@@ -26,7 +25,7 @@
 public abstract class WriteOperationFutureCallback<T> implements FutureCallback<T> {
 
   @Override
-  public final void onSuccess(@NullableDecl T t) {}
+  public final void onSuccess(T t) {}
 
   public abstract void onFailure(Throwable throwable);
 }
@@ -45,7 +45,6 @@
 import org.apache.hadoop.hbase.client.Mutation;
 import org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException;
 import org.apache.hadoop.hbase.client.Row;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * {@link MirroringBufferedMutator} implementation that performs writes to primary and secondary
@@ -204,7 +203,7 @@ public void run() {
         this.mirroringTracer.spanFactory.wrapWithCurrentSpan(
             new FutureCallback<Void>() {
               @Override
-              public void onSuccess(@NullableDecl Void aVoid) {
+              public void onSuccess(Void aVoid) {
                 flushFinished.run();
               }
 
@@ -225,7 +224,7 @@ public void onFailure(Throwable throwable) {
         this.mirroringTracer.spanFactory.wrapWithCurrentSpan(
             new FutureCallback<Void>() {
               @Override
-              public void onSuccess(@NullableDecl Void aVoid) {
+              public void onSuccess(Void aVoid) {
                 flushFinished.run();
               }
 

@@ -49,7 +49,6 @@
 import org.apache.hadoop.hbase.client.Mutation;
 import org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException;
 import org.apache.hadoop.hbase.client.Row;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * {@link MirroringBufferedMutator} implementation that performs mutations on secondary database
@@ -249,7 +248,7 @@ protected FlushFutures scheduleFlushScoped(
         this.mirroringTracer.spanFactory.wrapWithCurrentSpan(
             new FutureCallback<Void>() {
               @Override
-              public void onSuccess(@NullableDecl Void aVoid) {
+              public void onSuccess(Void aVoid) {
                 primaryFlushErrorsReported.set(null);
                 performSecondaryFlush(
                     dataToFlush,

@@ -42,7 +42,6 @@
 import org.apache.hadoop.hbase.client.Row;
 import org.apache.hadoop.hbase.client.RowMutations;
 import org.apache.hadoop.hbase.client.Table;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 public class BatchHelpers {
   public static FutureCallback<Void> createBatchVerificationCallback(
@@ -55,7 +54,7 @@ public static FutureCallback<Void> createBatchVerificationCallback(
       final MirroringTracer mirroringTracer) {
     return new FutureCallback<Void>() {
       @Override
-      public void onSuccess(@NullableDecl Void t) {
+      public void onSuccess(Void t) {
         // Batch is successful - all results are correct.
         List<? extends Row> secondaryOperations =
             failedAndSuccessfulPrimaryOperations.successfulOperations;

@@ -50,7 +50,6 @@
 import org.apache.hadoop.hbase.client.Row;
 import org.apache.hadoop.hbase.client.Table;
 import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * Helper class that handles logic related to mirroring {@link Table#batch(List, Object[])}
@@ -310,7 +309,7 @@ private ListenableFuture<BatchData> scheduleSecondaryWriteBatchOperations(
     FutureCallback<Void> verificationCallback =
         new FutureCallback<Void>() {
           @Override
-          public void onSuccess(@NullableDecl Void aVoid) {
+          public void onSuccess(Void aVoid) {
             verificationFuture.onSuccess(aVoid);
           }
 
@@ -426,7 +425,7 @@ public ListenableFuture<Void> get() {
     FutureCallback<Void> verification =
         new FutureCallback<Void>() {
           @Override
-          public void onSuccess(@NullableDecl Void result) {}
+          public void onSuccess(Void result) {}
 
           @Override
           public void onFailure(Throwable throwable) {
@@ -438,9 +437,8 @@ public void onFailure(Throwable throwable) {
     // handler.
     Function<Throwable, Void> flowControlReservationErrorConsumer =
         new Function<Throwable, Void>() {
-          @NullableDecl
           @Override
-          public Void apply(@NullableDecl Throwable throwable) {
+          public Void apply(Throwable throwable) {
             flowControllerException[0] = throwable;
             return null;
           }

@@ -29,7 +29,6 @@
 import com.google.common.util.concurrent.SettableFuture;
 import io.opencensus.common.Scope;
 import java.util.concurrent.ExecutionException;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * Static helper methods used for scheduling secondary database requests and results verification.
@@ -101,7 +100,7 @@ FutureCallback<? super T> wrapCallbackWithReleasingReservationAndCompletingFutur
     return mirroringTracer.spanFactory.wrapWithCurrentSpan(
         new FutureCallback<T>() {
           @Override
-          public void onSuccess(@NullableDecl T t) {
+          public void onSuccess(T t) {
             try {
               Log.trace("starting verification %s", t);
               callback.onSuccess(t);

@@ -40,7 +40,6 @@
 import java.io.IOException;
 import java.util.concurrent.Callable;
 import java.util.concurrent.TimeUnit;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 /**
  * Used to create named spans for tracing (using {@link #tracer}) and recording metrics related to
@@ -74,7 +73,7 @@ public <T> FutureCallback<? super T> wrapWithCurrentSpan(final FutureCallback<T>
     final Span span = getCurrentSpan();
     return new FutureCallback<T>() {
       @Override
-      public void onSuccess(@NullableDecl T t) {
+      public void onSuccess(T t) {
         try (Scope scope = spanAsScope(span)) {
           callback.onSuccess(t);
         }
@@ -152,7 +151,7 @@ public <T> T wrapSecondaryOperation(
   public <T> FutureCallback<T> wrapReadVerificationCallback(final FutureCallback<T> callback) {
     return new FutureCallback<T>() {
       @Override
-      public void onSuccess(@NullableDecl T t) {
+      public void onSuccess(T t) {
         try (Scope scope = MirroringSpanFactory.this.verificationScope()) {
           callback.onSuccess(t);
         }
@@ -175,7 +174,7 @@ public <T> FutureCallback<T> wrapWriteOperationCallback(
     // it.
     return new FutureCallback<T>() {
       @Override
-      public void onSuccess(@NullableDecl T t) {
+      public void onSuccess(T t) {
         mirroringTracer.metricsRecorder.recordSecondaryWriteErrors(operation, 0);
       }
 

@@ -25,7 +25,6 @@
 import org.apache.hadoop.hbase.client.Get;
 import org.apache.hadoop.hbase.client.Result;
 import org.apache.hadoop.hbase.client.Scan;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 
 @InternalApi("For internal usage only")
 public class VerificationContinuationFactory {
@@ -43,7 +42,7 @@ public MismatchDetector getMismatchDetector() {
   public FutureCallback<Boolean> exists(final Get request, final boolean expectation) {
     return new FutureCallback<Boolean>() {
       @Override
-      public void onSuccess(@NullableDecl Boolean secondary) {
+      public void onSuccess(Boolean secondary) {
         Log.trace("verification onSuccess exists(Get)");
         VerificationContinuationFactory.this.mismatchDetector.exists(
             request, expectation, secondary);
@@ -60,7 +59,7 @@ public void onFailure(Throwable throwable) {
   public FutureCallback<boolean[]> existsAll(final List<Get> request, final boolean[] expectation) {
     return new FutureCallback<boolean[]>() {
       @Override
-      public void onSuccess(@NullableDecl boolean[] secondary) {
+      public void onSuccess(boolean[] secondary) {
         Log.trace("verification onSuccess existsAll(List<Get>)");
         VerificationContinuationFactory.this.mismatchDetector.existsAll(
             request, expectation, secondary);
@@ -77,7 +76,7 @@ public void onFailure(Throwable throwable) {
   public FutureCallback<Result> get(final Get request, final Result expectation) {
     return new FutureCallback<Result>() {
       @Override
-      public void onSuccess(@NullableDecl Result secondary) {
+      public void onSuccess(Result secondary) {
         Log.trace("verification onSuccess get(Get)");
         VerificationContinuationFactory.this.mismatchDetector.get(request, expectation, secondary);
       }
@@ -93,7 +92,7 @@ public void onFailure(Throwable throwable) {
   public FutureCallback<Result[]> get(final List<Get> request, final Result[] expectation) {
     return new FutureCallback<Result[]>() {
       @Override
-      public void onSuccess(@NullableDecl Result[] secondary) {
+      public void onSuccess(Result[] secondary) {
         Log.trace("verification onSuccess get(List<Get>)");
         VerificationContinuationFactory.this.mismatchDetector.get(request, expectation, secondary);
       }
@@ -122,7 +121,7 @@ public FutureCallback<Void> scannerNext(
       final MismatchDetector.ScannerResultVerifier unmatched) {
     return new FutureCallback<Void>() {
       @Override
-      public void onSuccess(@NullableDecl Void ignored) {
+      public void onSuccess(Void ignored) {
         synchronized (verificationLock) {
           AsyncScannerVerificationPayload results = resultQueue.remove();
           Log.trace("verification onSuccess scannerNext(Scan, int)");

@@ -56,7 +56,6 @@
 import java.util.concurrent.TimeoutException;
 import org.apache.hadoop.hbase.client.ResultScanner;
 import org.apache.hadoop.hbase.client.Scan;
-import org.checkerframework.checker.nullness.compatqual.NullableDecl;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.function.ThrowingRunnable;
@@ -280,7 +279,7 @@ private FutureCallback<AsyncScannerVerificationPayload> addContextToListCallback
     return new FutureCallback<AsyncScannerVerificationPayload>() {
       @Override
       public void onSuccess(
-          @NullableDecl AsyncScannerVerificationPayload asyncScannerVerificationPayload) {
+          AsyncScannerVerificationPayload asyncScannerVerificationPayload) {
         list.add(asyncScannerVerificationPayload.context);
       }
 

@@ -72,24 +72,6 @@
       ],
       "groupName": "jackson dependencies"
     },
-    {
-      // pin to beam deps
-      "packagePatterns": ["^beam-slf4j.version"],
-      "enabled": false
-    },
-    {
-      // pin to hbase deps
-      "packagePatterns": [
-        "^hbase.-hadoop-slf4j.version",
-        "^hbase.-mapreduce-slfj.version"
-      ],
-      "enabled": false
-    },
-    {
-      // pin to bigtable version
-      "packagePatterns": ["^grpc-conscrypt.version"],
-      "enabled": false
-    },
     {
       // pinned to avoid internal deps conflict between beam-sdks-java-core & beam-model-pipeline
       "packagePatterns": ["^error_prone_annotations"],
@@ -107,6 +89,7 @@
         "^com.google.cloud:google-cloud-bigtable",
         "^com.google.cloud:google-cloud-bigtable-emulator-core",
         "^com.google.cloud:google-cloud-bigtable-emulator",
+        "^com.google.cloud:google-cloud-shared-config",
       ],
       "groupName": "google-cloud-bigtable dependencies"
     }