Fix lint

Author: Tony Cui

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/CancellationSharer.java

@@ -20,12 +20,10 @@
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutureCallback;
 import com.google.api.core.ApiFutures;
-import com.google.api.gax.rpc.ApiException;
 import com.google.common.util.concurrent.MoreExecutors;
 import com.google.pubsub.v1.PublishResponse;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -53,7 +51,9 @@ private void cleanupLocked() {
   }
 
   CancellationSharer(
-      final Publisher.OutstandingBatch batch, final Publisher publisher, final long absoluteDeadlineMs) {
+      final Publisher.OutstandingBatch batch,
+      final Publisher publisher,
+      final long absoluteDeadlineMs) {
     this.batch = batch;
     this.publisher = publisher;
     this.absoluteDeadlineMs = absoluteDeadlineMs;

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenTelemetryPubsubTracer.java

@@ -189,7 +189,7 @@ void endPublishBatchingSpan(PubsubMessageWrapper message) {
    * Creates, starts, and returns a publish RPC span for the given message batch. Bi-directional
    * links with the publisher parent span are created for sampled messages in the batch.
    *
-   * Note: Hedged publish attempts do not create distinct publish RPC spans. Instead, we rely on
+   * <p>Note: Hedged publish attempts do not create distinct publish RPC spans. Instead, we rely on
    * the hedged publish start and end events on each message.
    */
   Span startPublishRpcSpan(TopicName topicName, List<PubsubMessageWrapper> messages) {

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java

@@ -49,7 +49,6 @@
 import com.google.cloud.pubsub.v1.stub.PublisherStubSettings;
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Preconditions;
-import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
 import com.google.protobuf.CodedOutputStream;
 import com.google.pubsub.v1.PublishRequest;
@@ -569,15 +568,13 @@ private ApiFuture<PublishResponse> publishCall(
     for (PubsubMessageWrapper messageWrapper : messageWrappers) {
       if (attemptNumber == 0) {
         tracer.endPublishBatchingSpan(messageWrapper);
-      }
-      else{
+      } else {
         tracer.addHedgedPublishStartEvent(messageWrapper);
       }
       pubsubMessagesList.add(messageWrapper.getPubsubMessage());
     }
 
-    outstandingBatch.publishRpcSpan =
-      tracer.startPublishRpcSpan(topicNameObject, messageWrappers);
+    outstandingBatch.publishRpcSpan = tracer.startPublishRpcSpan(topicNameObject, messageWrappers);
 
     return publisherStub
         .publishCallable()

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PubsubMessageWrapper.java

@@ -186,14 +186,14 @@ void setSubscribeProcessSpan(Span span) {
   /** Creates a publish start event that is tied to the publish RPC span time. */
   void addPublishStartEvent() {
     if (publisherSpan != null) {
-        publisherSpan.addEvent(PUBLISH_START_EVENT);
+      publisherSpan.addEvent(PUBLISH_START_EVENT);
     }
   }
 
   /** Creates a hedged publish start event on the publisher span. */
   void addHedgedPublishStartEvent() {
     if (publisherSpan != null) {
-        publisherSpan.addEvent(HEDGED_PUBLISH_START_EVENT);
+      publisherSpan.addEvent(HEDGED_PUBLISH_START_EVENT);
     }
   }
 

java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/OpenTelemetryTest.java

@@ -670,7 +670,7 @@ public void testHedgedPublishSpanEvents() {
     OpenTelemetryPubsubTracer tracer = new OpenTelemetryPubsubTracer(openTelemetryTracer, true);
 
     // Start Publisher span
-       tracer.startPublisherSpan(messageWrapper);
+    tracer.startPublisherSpan(messageWrapper);
 
     // Original Attempt 0 (creates RPC span and emits initial publish start event)
     Span publishRpcSpan1 = tracer.startPublishRpcSpan(FULL_TOPIC_NAME, messageWrappers);
@@ -682,7 +682,6 @@ public void testHedgedPublishSpanEvents() {
     // End Publisher span
     tracer.endPublisherSpan(messageWrapper, true);
 
-
     List<SpanData> allSpans = openTelemetryTesting.getSpans();
     // 2 Spans: publishRpcSpan1, publisherSpan
     assertEquals(2, allSpans.size());

java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java

@@ -36,7 +36,6 @@
 import com.google.api.gax.rpc.DataLossException;
 import com.google.api.gax.rpc.FixedTransportChannelProvider;
 import com.google.api.gax.rpc.InvalidArgumentException;
-import com.google.api.gax.rpc.PermissionDeniedException;
 import com.google.api.gax.rpc.TransportChannelProvider;
 import com.google.cloud.pubsub.v1.Publisher.Builder;
 import com.google.protobuf.ByteString;
@@ -1707,7 +1706,6 @@ public void testPermanentErrorOnHedgedAttemptDiscarded() throws Exception {
     shutdownTestPublisher(publisher);
   }
 
-
   private Builder getTestPublisherBuilder() {
     return Publisher.newBuilder(TEST_TOPIC)
         .setExecutorProvider(FixedExecutorProvider.create(fakeExecutor))