fixed spotless complains

xianhualiu · Apr 10, 2024 · 37e267c · 37e267c
1 parent a647f88
commit 37e267c
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
@@ -832,15 +832,14 @@ static <K, V> void setupExternalBuilder(
         // implementation.
         builder.setDynamicRead(false);
 
-        if(config.consumerPollingTimeoutSeconds != null) {
-          if(config.consumerPollingTimeoutSeconds <= 0) {
+        if (config.consumerPollingTimeoutSeconds != null) {
+          if (config.consumerPollingTimeoutSeconds <= 0) {
             throw new IllegalArgumentException("consumerPollingTimeoutSeconds should be > 0.");
           }
           builder.setConsumerPollingTimeout(
               Duration.standardSeconds(config.consumerPollingTimeoutSeconds));
         } else {
-          builder.setConsumerPollingTimeout(
-              Duration.standardSeconds(2L));
+          builder.setConsumerPollingTimeout(Duration.standardSeconds(2L));
         }
       }